[23.09.2020] sending testing
This commit is contained in:
parent
9cdb599cf4
commit
e035c4cf71
@ -19,7 +19,7 @@ def activeMQSender(message, logger):
|
|||||||
addr, port, mqUser, mqPass = keys().returnKeys()
|
addr, port, mqUser, mqPass = keys().returnKeys()
|
||||||
|
|
||||||
logger.info("Attempting Connection to Artemis...")
|
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.connect( mqUser, mqPass, wait=True)
|
||||||
|
|
||||||
con.send("PricingSave.dlq", message, content_type="application/json", headers={"Content-Type":"application/json"})
|
con.send("PricingSave.dlq", message, content_type="application/json", headers={"Content-Type":"application/json"})
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user