diff --git a/src/utils/activemqConnect.py b/src/utils/activemqConnect.py index d26faab..f60e19b 100644 --- a/src/utils/activemqConnect.py +++ b/src/utils/activemqConnect.py @@ -22,5 +22,5 @@ def activeMQSender(message, logger): con = stomp.Connection([(addr, port)]) con.connect( mqUser, mqPass, wait=True) - con.send(message, 'PricingSave.dlq/queues/anycast/PricingSave.dlq') + con.send('PricingSave.dlq/queues/anycast/PricingSave.dlq', message)