21 lines
535 B
Python
21 lines
535 B
Python
import sys
|
|
from zmq import FORWARDER, PUB, SUB, SUBSCRIBE
|
|
from zmq.devices import Device
|
|
|
|
|
|
if __name__ == "__main__":
|
|
usage = 'usage: chat_bridge sub_address pub_address'
|
|
if len(sys.argv) != 3:
|
|
print(usage)
|
|
sys.exit(1)
|
|
|
|
sub_addr = sys.argv[1]
|
|
pub_addr = sys.argv[2]
|
|
print("Recieving on %s" % sub_addr)
|
|
print("Sending on %s" % pub_addr)
|
|
device = Device(FORWARDER, SUB, PUB)
|
|
device.bind_in(sub_addr)
|
|
device.setsockopt_in(SUBSCRIBE, "")
|
|
device.bind_out(pub_addr)
|
|
device.start()
|