diff --git a/src/utils/activemqConnect.py b/src/utils/activemqConnect.py index a580051..a310919 100644 --- a/src/utils/activemqConnect.py +++ b/src/utils/activemqConnect.py @@ -19,7 +19,7 @@ def activeMQSender(message, logger): addr, port, mqUser, mqPass = keys().returnKeys() logger.info("Attempting Connection to Artemis...") - con = stomp.Connection([(addr, port)]) + con = stomp.Connection([(addr, port)], auto_content_length=False) con.connect( mqUser, mqPass, wait=True) con.send("PricingSave.dlq", message, content_type="application/json", headers={"Content-Type":"application/json"})