aboutsummaryrefslogtreecommitdiffstats
path: root/bin/send_msg
blob: f284f00f5bbfbcfcb71486796a88fa2cad5bb6a0 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
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': '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)