From 2010a0134f22771bc7392fabe42103f47ba6b3f1 Mon Sep 17 00:00:00 2001 From: Andy Sotheran Date: Wed, 23 Sep 2020 22:23:54 +0100 Subject: [PATCH] [23.09.2020] sending testing --- src/utils/activemqConnect.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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()