diff options
| author | sideshowdave7 | 2017-02-10 10:24:33 -0700 |
|---|---|---|
| committer | sideshowdave7 | 2017-02-10 10:24:33 -0700 |
| commit | b5ef0e3845e68ae871bd6da8478fefaaee10fb14 (patch) | |
| tree | b98327341185e2eefcbcafc6dfe0d07a4c0d14f4 /bin | |
| parent | 7820331fd493d17513ca412a927e556ec0dd0a05 (diff) | |
| download | eventmq-b5ef0e3845e68ae871bd6da8478fefaaee10fb14.tar.gz eventmq-b5ef0e3845e68ae871bd6da8478fefaaee10fb14.zip | |
demo stuff
Diffstat (limited to 'bin')
| -rwxr-xr-x | bin/send_msg | 2 | ||||
| -rwxr-xr-x | bin/send_publish | 12 |
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 | ||