#!/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': 'path.to.some.module:Class', 'callable': 'do_thing', 'class_args': ('blurp',), 'class_kwargs': {'kwarg1': True}, 'args': ('arg1', 'arg2'), 'kwargs': {'kwarg1': 'something'} }] send_request(s, msg, guarantee=True, reply_requested=True) print zmq.POLLOUT events = dict(poller.poll(500)) print events if events[s.zsocket] == zmq.POLLIN: msg = s.recv_multipart() print msg