diff --git a/src/pricing/collector.py b/src/pricing/collector.py index 6c62cac..7328635 100644 --- a/src/pricing/collector.py +++ b/src/pricing/collector.py @@ -15,6 +15,8 @@ from pricing.exchanges.kraken import krakenVolAskBid, krakenHighLow, krakenOpenC from src.utils.databaseConnect import send from src.utils.activemqConnect import activeMQSender +import json + import logging as logger logger.basicConfig( @@ -124,9 +126,11 @@ def sentToArtemis(c_type, timestamp, av_price, high, low, vol, o_price, c_price) "volume" : vol } + messageJson = json.dumps(message, indent = 4) + logger.info("Sending message to PricingSave queue") - activeMQSender(message, logger) + activeMQSender(messageJson, logger) def timeFunction():