如何将 HornetQ 日志记录委托给 Slf4j

Question

我希望将嵌入在我的应用程序中运行的 HornetQ 的所有日志记录委托给 slf4j。不幸的是任何尝试都失败了。我已经尝试

• 添加 jul-to-slf4j
• 安装桥 SLF4JBridgeHandler.install();
• 尝试了 Log4jLogDelegateFactory （“hornetq-configuration.xml”通过org.hornetq.integration.logging.Log4jLogDelegateFactory)
• 编写了我自己的LogDelegate 和 LogDelegateFactory

但无论我做什么，以下几行都不会被捕获：

13.07.2011 17:42:11 org.hornetq.core.logging.impl.JULLogDelegate warn
WARNUNG: AIO wasn't located on this platform, it will fall back to using pure Java NIO. If your platform is Linux, install LibAIO to enable the AIO journal
13.07.2011 17:42:11 org.hornetq.core.logging.impl.JULLogDelegate info
INFO: Using NIO Journal
13.07.2011 17:42:11 org.hornetq.core.logging.impl.JULLogDelegate info
INFO: Started Netty Acceptor version 3.1.5.GA-r1772

我错过了什么？

Answer 1

我找到了一个完整的解决方案，我想与您分享。
我之前已经单独尝试过其中每一个，但是您必须结合其他答案中提到的一些技术。

• 您需要编写自己的 LogDelegate：

import org.hornetq.spi.core.logging.LogDelegate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Slf4jLogDelegate implements LogDelegate {
    private final Logger logger;
    public Slf4jLogDelegate(Class clazz) {
        logger = LoggerFactory.getLogger(clazz);
    }
    @Override
    public void debug(Object message) {
        logger.debug(message.toString());
    }
    @Override
    public void debug(Object message, Throwable t) {
        logger.debug(message.toString(), t);
    }
    @Override
    public void error(Object message) {
        logger.error(message.toString());
    }
    @Override
    public void error(Object message, Throwable t) {
        logger.error(message.toString(), t);
    }
    @Override
    public void fatal(Object message) {
        logger.error(message.toString());
    }
    @Override
    public void fatal(Object message, Throwable t) {
        logger.error(message.toString(), t);
    }
    @Override
    public void info(Object message) {
        logger.info(message.toString());
    }
    @Override
    public void info(Object message, Throwable t) {
        logger.info(message.toString(), t);
    }
    @Override
    public boolean isDebugEnabled() {
        return logger.isDebugEnabled();
    }
    @Override
    public boolean isInfoEnabled() {
        return logger.isInfoEnabled();
    }
    @Override
    public boolean isTraceEnabled() {
        return logger.isTraceEnabled();
    }
    @Override
    public void trace(Object message) {
        logger.trace(message.toString());
    }
    @Override
    public void trace(Object message, Throwable t) {
        logger.trace(message.toString(), t);
    }
    @Override
    public void warn(Object message) {
        logger.warn(message.toString());
    }
    @Override
    public void warn(Object message, Throwable t) {
        logger.warn(message.toString(), t);
    }
}

• 然后您需要编写工厂：

import org.hornetq.spi.core.logging.LogDelegate;
import org.hornetq.spi.core.logging.LogDelegateFactory;
public class Slf4jLogDelegateFactory implements LogDelegateFactory {
    // Maybe caching of delegates makes sense?
    @Override
    public LogDelegate createDelegate(Class clazz) {
        return new Slf4jLogDelegate(clazz);
    }
}

• 然后将以下行添加到您的 hornetq-configuration.xml 中：
  yourpackage.Slf4jLogDelegateFactory
• 最后，在启动嵌入式服务器之前添加以下行：
  org.hornetq.core.logging.Logger.setDelegateFactory(new Slf4jLogDelegateFactory());

我只是想知道为什么他们不能使用经过验证的日志机制，这样可以轻松交换记录器。

Answer 2

由于您正在运行嵌入式，请尝试在启动服务器之前添加以下代码：

org.hornetq.core.logging.Logger.setDelegateFactory(new YourOwnDelegateFactory())

您可能会收到一些使用旧委托的消息，直到服务器从配置。

Answer 3

在尝试此操作时，我还发现，当 HornetQServerImpl 初始化其静态日志时，它会在加载新的 LogDelegateFactory 之前执行此操作，因此不要使用我在 hornetq 上指定的日志-configuration.xml 它使用 JULLogDelegateFactory 因此其日志直接输出到控制台。

深入研究 HornetQ 的代码，我发现它在 Logger.initialise() 上初始化它，并且它还在其中查找名为“org.hornetq.logger-delegate-factory-class-”的系统属性name" 设置默认工厂，所以我用它来解决我的问题。

我已经使用 Spring 修复了这个问题：

<!-- This property must be set so HornetQServerImpl logger uses our factory -->
<bean id="systemPrereqs" class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
    <property name="targetClass" value="java.lang.System" />
    <property name="targetMethod" value="setProperty" />
    <property name="arguments">
        <list>
            <value>org.hornetq.logger-delegate-factory-class-name</value>
            <value>my.Slf4jLogDelegateFactory</value>
        </list>
    </property>
</bean>