andyjk15/price-collector
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[23.09.2020] sending testing

Browse Source
This commit is contained in:
Andy Sotheran 2020-09-23 22:23:54 +01:00
parent 80b3485138
commit 2010a0134f
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/utils/activemqConnect.py
View File

@ -20,7 +20,10 @@ def activeMQSender(message, logger):
logger.info("Attempting Connection to Artemis...") logger.info("Attempting Connection to Artemis...")
con = stomp.Connection([(addr, port)]) con = stomp.Connection([(addr, port)])
con.start()
con.connect( mqUser, mqPass, wait=True) con.connect( mqUser, mqPass, wait=True)
con.send(message, destination="/PricingSave.dlq" ) con.send(message, destination="/topic/event" )
con.disconnect()