27 lines
699 B
Python
27 lines
699 B
Python
#!/usr/bin/env python
|
|
|
|
import stomp
|
|
import os
|
|
|
|
class keys():
|
|
|
|
def __init__(self):
|
|
self.uri = os.getenv("AMQ_URL")
|
|
self.amqU = os.getenv("BROKER_USER")
|
|
self.amqP = os.getenv("BROKER_PASSWORD")
|
|
self.addr = self.uri.split(':')[0]
|
|
self.port = self.uri.split(':')[1]
|
|
|
|
def returnKeys(self):
|
|
return self.addr, self.port, self.amqU, self.amqP
|
|
|
|
def activeMQSender(message, logger):
|
|
addr, port, mqUser, mqPass = keys().returnKeys()
|
|
|
|
logger.info("Attempting Connection to Artemis...")
|
|
con = stomp.Connection([(addr, port)])
|
|
con.connect( mqUser, mqPass, wait=True)
|
|
|
|
con.send('PricingSave.dlq/queues/anycast/PricingSave.dlq', message)
|
|
|