diff --git a/src/utils/activemqConnect.py b/src/utils/activemqConnect.py index da87a91..ddbf76a 100644 --- a/src/utils/activemqConnect.py +++ b/src/utils/activemqConnect.py @@ -22,7 +22,7 @@ def activeMQSender(message, logger): con = stomp.Connection([(addr, port)]) con.connect( mqUser, mqPass, wait=True) - con.send("PricingSave.dlq", message, headers={"Content-Type":"application/text"}) + con.send("PricingSave.dlq", message, headers={"Content-Type":"application/json"}) con.disconnect()