#!/usr/bin/env python
"""
Usage: ./send_msg <ipaddresss> <command> <frame w/ values space separated>
"""
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': 'work_job',
            'class_args': ('blurp',),
            'class_kwargs': {'kwarg1': True},
            'args': (10, ),
            'kwargs': {}
            }]

        msgid = send_request(s, msg, guarantee=True, reply_requested=True, timeout=10, queue='other')
        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