#!/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(message, 'PricingSave.dlq/queues/anycast/PricingSave.dlq')