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:57:42 +01:00
parent 774c17d6e8
commit b85dd30dc3
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/pricing/collector.py
View File

@ -126,9 +126,9 @@ def sentToArtemis(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
"volume" : vol "volume" : vol
} }
# messageJson = json.dumps(message, indent = 4) messageJson = json.dumps(message, indent = 4)
messageJson = str(message) # messageJson = str(message)
logger.info("Sending message to PricingSave queue") logger.info("Sending message to PricingSave queue")

4
src/utils/activemqConnect.py
View File

@ -22,5 +22,7 @@ def activeMQSender(message, logger):
con = stomp.Connection([(addr, port)]) con = stomp.Connection([(addr, port)])
con.connect( mqUser, mqPass, wait=True) con.connect( mqUser, mqPass, wait=True)
con.send("PricingSave.dlq", message) con.send("PricingSave", message)
con.disconnect()