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