eventlet/examples/chat_bridge.py

   1 import sys
   2 from zmq import FORWARDER, PUB, SUB, SUBSCRIBE
   3 from zmq.devices import Device
   4
   5
   6 if __name__ == "__main__":
   7     usage = 'usage: chat_bridge sub_address pub_address'
   8     if len(sys.argv) != 3:
   9         print(usage)
  10         sys.exit(1)
  11
  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)
  20     device.start()