Finish better worker PR

1 files changed, 14 insertions, 13 deletions

diff --git a/bin/send_msg b/bin/send_msg
index 652010c..47de45f 100755
--- a/bin/send_msg
+++ b/bin/send_msg
@@ -19,22 +19,23 @@ if __name__ == "__main__":
 
         msg = ['run', {
             'path': 'eventmq.tests.test_jobmanager',
-            'callable': 'pretend_job',
+            'callable': 'work_job',
             'class_args': ('blurp',),
             'class_kwargs': {'kwarg1': True},
-            'args': (10, ),
+            'args': (50, ),
             'kwargs': {}
             }]
 
-        msgid = send_request(s, msg, guarantee=True, reply_requested=True, timeout=200)
-        print 'Sent message, use msgid={} to track responses'.format(msgid)
-        events = dict(poller.poll(500))
-        if events[s.zsocket] == zmq.POLLIN:
-            msg = s.recv_multipart()
-            print msg
+        msgid = send_request(s, msg, guarantee=True, reply_requested=True, timeout=10)
+        msgid = send_request(s, msg, guarantee=True, reply_requested=True)
+        # print 'Sent message, use msgid={} to track responses'.format(msgid)
+        # events = dict(poller.poll(500))
+        # if events[s.zsocket] == zmq.POLLIN:
+        #     msg = s.recv_multipart()
+        #     print msg
 
-        # Wait for job reply
-        events = dict(poller.poll(50000))
-        if events[s.zsocket] == zmq.POLLIN:
-            msg = s.recv_multipart()
-            print msg
+        # # Wait for job reply
+        # events = dict(poller.poll(50000))
+        # if events[s.zsocket] == zmq.POLLIN:
+        #     msg = s.recv_multipart()
+        #     print msg