python activemq example

client

#!/usr/bin/env python
import time
import sys

import stomp
from stomp import *

conn = stomp.Connection()
conn.start()
conn.connect('admin', 'admin', wait=True)
conn.send(body='{"foo":"bar"}', destination='/queue/test')
conn.disconnect()

server

#!/usr/bin/env python
import time
import stomp
from stomp import *

class MyListener(stomp.ConnectionListener):
    def on_error(self, headers, message):
        print('received an error "%s"' % message)
    def on_message(self, headers, message):
        print('received a message "%s"' % message)

def reconnect():
    conn =  stomp.Connection(keepalive=True)
    conn.set_listener('ilisten', MyListener())
    conn.start()
    conn.connect('admin', 'admin', wait=True)
    conn.subscribe(destination='/queue/test', id=1, ack='auto')
    return conn


conn = reconnect()
while True:
    time.sleep(1)
    if not conn.is_connected():
        time.sleep(5)
        conn = reconnect()

conn.disconnect()