stomp_py_listener_subscribe_and_send_message.py

1import time
2import sys
3import stomp
4
5class MyListener(stomp.ConnectionListener):
6    def on_error(self, frame):
7        print('received an error "%s"' % frame.body)
8
9    def on_message(self, frame):
10        print('received a message "%s"' % frame.body)
11
12conn = stomp.Connection([('127.0.0.1', 61613)])
13conn.set_listener('', MyListener())
14conn.connect('admin', 'password', wait=True)
15conn.subscribe(destination='/queue/test', id=1, ack='auto')
16
17conn.send(body=' '.join(sys.argv[1:]), destination='/queue/test')
18
19time.sleep(2)
20conn.disconnect()