version bump to 0.3.4

1 files changed, 12 insertions, 8 deletions

diff --git a/bin/send_msg b/bin/send_msg
index 95dc3de..652010c 100755
--- a/bin/send_msg
+++ b/bin/send_msg
@@ -22,15 +22,19 @@ if __name__ == "__main__":
             'callable': 'pretend_job',
             'class_args': ('blurp',),
             'class_kwargs': {'kwarg1': True},
-            'args': (2, ),
+            'args': (10, ),
             'kwargs': {}
             }]
 
-        send_request(s, msg, guarantee=True, reply_requested=True, timeout=1)
-        # print zmq.POLLOUT
-        # events = dict(poller.poll(500))
-        # print events
-        # if events[s.zsocket] == zmq.POLLIN:
-        #     msg = s.recv_multipart()
+        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
 
-        #     print msg
+        # Wait for job reply
+        events = dict(poller.poll(50000))
+        if events[s.zsocket] == zmq.POLLIN:
+            msg = s.recv_multipart()
+            print msg