From b85dd30dc3a26b7c769740667bb43fb24fc8fdc5 Mon Sep 17 00:00:00 2001
From: Andy Sotheran <andrew.sotheran@googlemail.com>
Date: Wed, 23 Sep 2020 22:57:42 +0100
Subject: [PATCH] [23.09.2020] sending testing

---
 src/pricing/collector.py     | 4 ++--
 src/utils/activemqConnect.py | 4 +++-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/pricing/collector.py b/src/pricing/collector.py
index fb8946c..b1deeec 100644
--- a/src/pricing/collector.py
+++ b/src/pricing/collector.py
@@ -126,9 +126,9 @@ def sentToArtemis(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
         "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")
 
diff --git a/src/utils/activemqConnect.py b/src/utils/activemqConnect.py
index 85ba18e..0977d38 100644
--- a/src/utils/activemqConnect.py
+++ b/src/utils/activemqConnect.py
@@ -22,5 +22,7 @@ def activeMQSender(message, logger):
     con = stomp.Connection([(addr, port)])
     con.connect( mqUser, mqPass, wait=True)
 
-    con.send("PricingSave.dlq", message)
+    con.send("PricingSave", message)
+
+    con.disconnect()