#!/usr/bin/env python """ Usage: ./send_msg """ import sys import zmq from eventmq.sender import Sender from eventmq.client.messages import send_request if __name__ == "__main__": for i in xrange(1): s = Sender() poller = zmq.Poller() poller.register(s.zsocket, flags=zmq.POLLIN) s.connect(sys.argv[1]) msg = ['run', { 'path': 'eventmq.tests.test_jobmanager', 'callable': 'pretend_job', 'class_args': ('blurp',), 'class_kwargs': {'kwarg1': True}, 'args': (2, ), '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() print msg