2 from zmq import FORWARDER, PUB, SUB, SUBSCRIBE
3 from zmq.devices import Device
6 if __name__ == "__main__":
7 usage = 'usage: chat_bridge sub_address pub_address'
12 sub_addr = sys.argv[1]
13 pub_addr = sys.argv[2]
14 print("Recieving on %s" % sub_addr)
15 print("Sending on %s" % pub_addr)
16 device = Device(FORWARDER, SUB, PUB)
17 device.bind_in(sub_addr)
18 device.setsockopt_in(SUBSCRIBE, "")
19 device.bind_out(pub_addr)