Merge pull request #35 from sideshowdave7/feature/replies_and_latency0.2.3

Feature: job latencies

1 files changed, 24 insertions, 0 deletions

diff --git a/bin/send_request b/bin/send_request
new file mode 100755
index 0000000..aa84639
--- /dev/null
+++ b/bin/send_request
@@ -0,0 +1,24 @@
+#!/usr/bin/env python
+"""
+Usage: ./send_msg <ipaddresss> <command> <frame w/ values space separated>
+"""
+import sys
+
+from eventmq.sender import Sender
+from eventmq.client.messages import send_request
+
+
+if __name__ == "__main__":
+    s = Sender()
+    s.connect(sys.argv[1])
+
+    msg = ['run', {
+           'path': 'eventmq.scheduler',
+           'callable': 'test_job',
+           'class_args': (),
+           'class_kwargs': {},
+           'args': (),
+           'kwargs': {}
+           }]
+
+    send_request(s, msg, guarantee=True, reply_requested=True)