In [ ]:

    

import stomp
import pprint
import time


    

In [ ]:

    

class Listener(stomp.ConnectionListener):

    can_stop = False
    def on_message(self, headers, message):
        if headers:
            print('\nHeaders:\n')
            pprint.pprint(headers)
        print('\nMessage Body:\n')
        print(message)
        self.can_stop = True


    

In [ ]:

    

listener = Listener()


    

In [ ]:

    

conn = stomp.Connection()
conn.set_listener('', listener)
conn.start()
conn.connect()


    

In [ ]:

    

conn.subscribe('/queue/stomp-messages', id=1, ack='auto')


    

In [ ]:

    

while not listener.can_stop:
    time.sleep(1)


    

In [ ]:

    

conn.disconnect()