blob: e0fd537575032bb62aacae76b01062363979280b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
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()
|
