change port and credentials for messages
This commit is contained in:
@@ -21,12 +21,12 @@ class MyListener(stomp.ConnectionListener):
|
||||
|
||||
if __name__ == '__main__':
|
||||
log = get_logger(args.verbose, args.config)
|
||||
host = [('127.0.0.1', 61613)]
|
||||
host = [('127.0.0.1', 61616)]
|
||||
conn = stomp.Connection(host_and_ports=host)
|
||||
conn.set_listener('', MyListener(log))
|
||||
conn.connect(username='smx', passcode='smx', wait=True)
|
||||
conn.subscribe(destination='/queue/queue-1', id=1, ack='auto', headers={})
|
||||
conn.send(body='{ "message": "test message"}', destination="/queue/queue-1")
|
||||
conn.connect(username='artemis', passcode='artemis', wait=True)
|
||||
conn.subscribe(destination='KontorMediaFile', id=1, ack='auto', headers={})
|
||||
conn.send(body='{ "message": "test message"}', destination="KontorMediaFile")
|
||||
time.sleep(10)
|
||||
conn.disconnect()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user