Sorry for there's typo on my question bellow, the port should be 6666
Thanks,
Uung
On Wed, Jul 28, 2010 at 1:25 PM, Uung H.R Bhuwono <avenp...@gmail.com> wrote:
> Hi,
>
> I've been trying to make use zeromq on my twisted daemon script
> When zeromq send message to the queue, this work since send_pyobj()
> return True.
> But the subscriber never get the message from queue using recv_pyobj()
> and it just freeze like there's nothing on the queue
>
> My twisted daemon script as a follow:
>
> - serve_message.py
> class MyService(service.Service):
> def __init__(self):
> pass
> def startService(self):
> c = zmq.Context(1)
> s = c.socket(zmq.PUB)
> s.bind("tcp://127.0.0.1:6666")
> s.send_pyobj("helo there")
> def stopService(self):
> pass
>
> def getMyService():
> myService = MyService()
> return myService
>
> application = service.Application("My Service Application")
>
> # attach the service to its parent application
> procd = getMyService()
> procd.setServiceParent(application)
>
> my simple subscriber script subscriber.py
>
> import zmq
> c = zmq.Context(1)
> s = c.socket(zmq.SUB)
> s.connect("tcp://127.0.0.1:9999")
> s.setsockopt(zmq.SUBSCRIBE, "")
> s.recv_pyobj()
>
> Does it possible to use zeromq with twisted daemon on Linux?
> Please help me to solve this
>
> Thanks,
>
> Uung
>
_______________________________________________
Twisted-Python mailing list
Twisted-Python@twistedmatrix.com
http://twistedmatrix.com/cgi-bin/mailman/listinfo/twisted-python
