[zeromq-dev] Help With Regard To the ZMQ Forwarder

[Symbian Projects]

Hello All,

I am trying to use ZMQ forwarder device , my use case is simple, i have two 
three clients and i want then send and receive message together.

I am using the following method to start my forwarder device:

import zmq

def startForwarder():
    context = zmq.Context(1)
    incoming = context.socket(zmq.SUB)

    try:
        incoming.connect("tcp://127.0.0.1:5551");
        incoming.setsockopt(zmq.SUBSCRIBE, "")
    except:
        print("incoming socket is already open")

    try:
        outgoing = context.socket(zmq.PUB)
        outgoing.bind('tcp://127.0.0.1:5562')
    except:
        print("outgoing socket is also open close it")

    zmq.device(zmq.FORWARDER, incoming, outgoing)
    


startForwarder()

It works ok for the first time but the next time i start it doesnt bind to the 
outgoing PUB port always gives me error something like :

 line 15, in startForwarder
    outgoing.bind('tcp://127.0.0.1:5562')
  File "socket.pyx", line 489, in zmq.core.socket.Socket.bind 
(zmq\core\socket.c:4797)
ZMQError: Address in use

Can anybody help me on this.

Thanks,
Ronald


                                          
_______________________________________________
zeromq-dev mailing list
zeromq-dev@lists.zeromq.org
http://lists.zeromq.org/mailman/listinfo/zeromq-dev