aboutsummaryrefslogtreecommitdiffstats
path: root/bin
diff options
context:
space:
mode:
authorsideshowdave72017-03-31 17:08:22 -0600
committersideshowdave72017-03-31 17:08:22 -0600
commit860a110aae76ac49a3ca78b0829a072a2de9ef6f (patch)
tree109bf50ce0e203d0e3005e6871fcef0c179e1706 /bin
parent5abee5f509beb45dc064931decf5e285b0c6a4b8 (diff)
downloadeventmq-860a110aae76ac49a3ca78b0829a072a2de9ef6f.tar.gz
eventmq-860a110aae76ac49a3ca78b0829a072a2de9ef6f.zip
create a better interface between worker and jobmanager
Diffstat (limited to 'bin')
-rwxr-xr-xbin/send_msg4
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