diff --git a/consumer.py b/consumer.py index 857ca1d..d3a8ccc 100644 --- a/consumer.py +++ b/consumer.py @@ -55,6 +55,10 @@ class MyListener(stomp.ConnectionListener): RestAPIClient.addDownloadFailure(message.body) +print("## ") +print("## starting > JMS consumer (yankee-sully-channels-monthly)") +print("## ") + conn = stomp.Connection([('osiris.yankee.embanet.online', 61613)]) conn.set_listener('', MyListener())