1#!/usr/bin/python 2from topology import * 3import zmq 4import sys 5 6T = Topology() 7net1 = Network(T, "pyt0") 8 9#h1 = Host(T, net1) 10h2 = Host(T, net1, args="zeromq_prod:") 11 12sleep(1) 13raw_input("Press enter to continue ...") 14start(T) 15 16# Zeromq part 17ctx = zmq.Context() 18z = ctx.socket(zmq.SUB) 19z.setsockopt(zmq.SUBSCRIBE, "") 20z.connect("tcp://172.16.1.2:1207") 21print "In the loop..." 22for i in range(20): 23 if z.poll(20000) == 0: 24 print "Timeout!!!" 25 cleanup() 26 sys.exit(1) 27 else: 28 msg = z.recv() 29 print "Recvd msg len=%d content: %s" % (len(msg), msg) 30 31 32 33 34cleanup() 35