ActiveMQ обработчик журналирования шины сообщений python

Question

Я хочу опубликовать сообщение в ActiveMQ, когда я LOG.debug или же LOG.info,

Я должен добавить обработчик logging,

Есть ли другой питонский способ сделать это?

Answer 1

Я создал новую ручку, чтобы справиться с этим

import json
import logging

from stompest.config import StompConfig
from stompest.sync import Stomp

class Handler(logging.Handler):
    def __init__(self, amq_uri, out_queue):
        logging.Handler.__init__(self)
        self.queue = queue
        self.uri = uri

    def emit(self, record):
        msg = self.format(record)
        cfg = StompConfig(self.uri)
        data = json.dumps(msg)
        client = Stomp(cfg)
        client.connect()

        try:
            client.send(self.queue, data)
        except Exception, exc:
            print "Error: ", exc
        client.disconnect()

def get_logger(uri, queue):
    logger = logging.getLogger('testlogger')
    logger.addHandler(Handler(uri, queue))