aboutsummaryrefslogtreecommitdiffstats
path: root/bin
diff options
context:
space:
mode:
authorsideshowdave72017-02-10 10:24:33 -0700
committersideshowdave72017-02-10 10:24:33 -0700
commitb5ef0e3845e68ae871bd6da8478fefaaee10fb14 (patch)
treeb98327341185e2eefcbcafc6dfe0d07a4c0d14f4 /bin
parent7820331fd493d17513ca412a927e556ec0dd0a05 (diff)
downloadeventmq-b5ef0e3845e68ae871bd6da8478fefaaee10fb14.tar.gz
eventmq-b5ef0e3845e68ae871bd6da8478fefaaee10fb14.zip
demo stuff
Diffstat (limited to 'bin')
-rwxr-xr-xbin/send_msg2
-rwxr-xr-xbin/send_publish12
2 files changed, 3 insertions, 11 deletions
diff --git a/bin/send_msg b/bin/send_msg
index b0ea160..19e88de 100755
--- a/bin/send_msg
+++ b/bin/send_msg
@@ -26,7 +26,7 @@ if __name__ == "__main__":
26 'kwargs': {} 26 'kwargs': {}
27 }] 27 }]
28 28
29 send_request(s, msg, guarantee=True, reply_requested=True, timeout=10) 29 send_request(s, msg, guarantee=True, reply_requested=True, timeout=1)
30 print zmq.POLLOUT 30 print zmq.POLLOUT
31 events = dict(poller.poll(500)) 31 events = dict(poller.poll(500))
32 print events 32 print events
diff --git a/bin/send_publish b/bin/send_publish
index 140be63..50f430e 100755
--- a/bin/send_publish
+++ b/bin/send_publish
@@ -12,13 +12,5 @@ if __name__ == "__main__":
12 s.connect(sys.argv[1]) 12 s.connect(sys.argv[1])
13 13
14 msg = ['update', '1'] 14 msg = ['update', '1']
15 j = 0 15 topic = str('topic')
16 while True: 16 send_publish_request(s, topic, msg)
17
18 for i in xrange(10):
19 topic = str(i)
20 send_publish_request(s, topic, msg)
21
22
23 print j
24 j += 1