diff --git a/src/utils/activemqConnect.py b/src/utils/activemqConnect.py
index 944cee0..3a46b0f 100644
--- a/src/utils/activemqConnect.py
+++ b/src/utils/activemqConnect.py
@@ -20,7 +20,10 @@ def activeMQSender(message, logger):
 
     logger.info("Attempting Connection to Artemis...")
     con = stomp.Connection([(addr, port)])
+    con.start()
     con.connect( mqUser, mqPass, wait=True)
 
-    con.send(message, destination="/PricingSave.dlq" )
+    con.send(message, destination="/topic/event" )
+
+    con.disconnect()