Skip to content

Instantly share code, notes, and snippets.

@tdpreece
Created September 28, 2015 19:30
Show Gist options
  • Save tdpreece/c79a4d0f75c49f024166 to your computer and use it in GitHub Desktop.
Save tdpreece/c79a4d0f75c49f024166 to your computer and use it in GitHub Desktop.
stomp.py example
# Python 2.7.6
# stomp.py v4.1.5 (https://pypi.python.org/pypi/stomp.py)
import time
import stomp
class MyListener(stomp.ConnectionListener):
def on_message(self, headers, message):
print('MyListener:\nreceived a message "{}"\n'.format(message))
global read_messages
read_messages.append({'id': headers['message-id'], 'subscription':headers['subscription']})
class MyStatsListener(stomp.StatsListener):
def on_disconnected(self):
super(MyStatsListener, self).on_disconnected()
print('MyStatsListener:\n{}\n'.format(self))
read_messages = []
hosts = [('localhost', 21613)]
conn = stomp.Connection(host_and_ports=hosts)
conn.set_listener('my_listener', MyListener())
conn.set_listener('stats_listener', MyStatsListener())
conn.start()
# wait=True means that it waits until it's established a connection with the server before returning.
conn.connect(wait=True)
# id should uniquely identify the subscription
# ack = auto, client, or client-individual
# See https://stomp.github.io/stomp-specification-1.1.html#SUBSCRIBE_ack_Header
conn.subscribe(destination='test.req', id=1, ack='client-individual')
conn.send(body="A Test message", destination='test.req')
time.sleep(3)
for message in read_messages:
conn.ack(message['id'], message['subscription'])
conn.disconnect()
# Script output ...
#
# MyListener:
# received a message "A Test message"
#
# MyStatsListener:
# Connections: 1
# Messages sent: 5
# Messages received: 1
# Errors: 0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment