diff options
| author | sideshowdave7 | 2017-03-31 17:08:22 -0600 |
|---|---|---|
| committer | sideshowdave7 | 2017-03-31 17:08:22 -0600 |
| commit | 860a110aae76ac49a3ca78b0829a072a2de9ef6f (patch) | |
| tree | 109bf50ce0e203d0e3005e6871fcef0c179e1706 /bin | |
| parent | 5abee5f509beb45dc064931decf5e285b0c6a4b8 (diff) | |
| download | eventmq-860a110aae76ac49a3ca78b0829a072a2de9ef6f.tar.gz eventmq-860a110aae76ac49a3ca78b0829a072a2de9ef6f.zip | |
create a better interface between worker and jobmanager
Diffstat (limited to 'bin')
| -rwxr-xr-x | bin/send_msg | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/bin/send_msg b/bin/send_msg index c58d369..95dc3de 100755 --- a/bin/send_msg +++ b/bin/send_msg | |||
| @@ -22,11 +22,11 @@ if __name__ == "__main__": | |||
| 22 | 'callable': 'pretend_job', | 22 | 'callable': 'pretend_job', |
| 23 | 'class_args': ('blurp',), | 23 | 'class_args': ('blurp',), |
| 24 | 'class_kwargs': {'kwarg1': True}, | 24 | 'class_kwargs': {'kwarg1': True}, |
| 25 | 'args': (1, ), | 25 | 'args': (2, ), |
| 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 |