diff options
| author | sideshowdave7 | 2017-01-04 13:41:10 -0700 |
|---|---|---|
| committer | sideshowdave7 | 2017-01-04 13:41:10 -0700 |
| commit | bddb5bcaa8a5d8c7b17dd2eeda9331b1d0b6bfc5 (patch) | |
| tree | 1cf62fb7866b59b2cd034a841f40a34f72579d4c /bin | |
| parent | ae51c941bc30dd175283c09e39f9e207e107a2a3 (diff) | |
| parent | af67b0979102fc4aa192444f510903d297d4c91d (diff) | |
| download | eventmq-bddb5bcaa8a5d8c7b17dd2eeda9331b1d0b6bfc5.tar.gz eventmq-bddb5bcaa8a5d8c7b17dd2eeda9331b1d0b6bfc5.zip | |
Merge master
Diffstat (limited to 'bin')
| -rwxr-xr-x | bin/send_msg | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/bin/send_msg b/bin/send_msg index 5c1806e..b0ea160 100755 --- a/bin/send_msg +++ b/bin/send_msg | |||
| @@ -18,15 +18,15 @@ if __name__ == "__main__": | |||
| 18 | s.connect(sys.argv[1]) | 18 | s.connect(sys.argv[1]) |
| 19 | 19 | ||
| 20 | msg = ['run', { | 20 | msg = ['run', { |
| 21 | 'path': 'path.to.some.module:Class', | 21 | 'path': 'eventmq.tests.test_jobmanager', |
| 22 | 'callable': 'do_thing', | 22 | 'callable': 'pretend_job', |
| 23 | 'class_args': ('blurp',), | 23 | 'class_args': ('blurp',), |
| 24 | 'class_kwargs': {'kwarg1': True}, | 24 | 'class_kwargs': {'kwarg1': True}, |
| 25 | 'args': ('arg1', 'arg2'), | 25 | 'args': (2, ), |
| 26 | 'kwargs': {'kwarg1': 'something'} | 26 | 'kwargs': {} |
| 27 | }] | 27 | }] |
| 28 | 28 | ||
| 29 | send_request(s, msg, guarantee=True, reply_requested=True) | 29 | send_request(s, msg, guarantee=True, reply_requested=True, timeout=10) |
| 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 |