将 log4j JMSAppender 与 ActiveMQ 结合使用 - 调试级别的有线格式超时（客户端）

Question

我正在尝试使用 log4j JMSappender 和 ActiveMQ 制作 POC。我成功地遵循了这个例子 -> http://activemq.apache.org/how-do-i-use-log4j-jms-appender-with-activemq.html

但这是 INFO 级别的。我做了一些修改以在 DEBUG 级别使用它，我的程序和 activeMQ 无法交换它们的有线格式。这是我的 log4j（客户端）

log4j.rootLogger=DEBUG, stdout, jms
log4j.logger.org.apache.activemq=INFO, stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %-5p %c - %m%n
log4j.appender.stdout.Threshold=INFO

log4j.appender.jms=org.apache.log4j.net.JMSAppender
log4j.appender.jms.InitialContextFactoryName=org.apache.activemq.jndi.ActiveMQInitialContextFactory
log4j.appender.jms.ProviderURL=tcp://localhost:61616
log4j.appender.jms.TopicBindingName=logTopic
log4j.appender.jms.TopicConnectionFactoryBindingName=ConnectionFactory
log4j.appender.jms.Threshold=DEBUG

当运行我的客户时，我有线格式错误。

生产者程序：

import org.apache.log4j.Logger;

public class ProducerDebug {

public static void main( String[] args ) throws InterruptedException
{
    new ProducerDebug();
}

private ProducerDebug() throws InterruptedException {
    Logger logger = Logger.getLogger(ProducerInfo.class);

    while (true)
    {
        logger.debug("push DEBUG");
        logger.info("push INFO2");
        Thread.sleep(10000);
    }
}
}

错误信息：

log4j:ERROR Error while activating options for appender named [jms]. javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:72) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1412) at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1501) at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:323) at org.apache.activemq.ActiveMQConnection.createTopicSession(ActiveMQConnection.java:1134) at org.apache.log4j.net.JMSAppender.activateOptions(JMSAppender.java:218) at org.apache.log4j.config.PropertySetter.activate(PropertySetter.java:307) at org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:172) at org.apache.log4j.config.PropertySetter.setProperties(PropertySetter.java:104) at org.apache.log4j.PropertyConfigurator.parseAppender(PropertyConfigurator.java:842) at org.apache.log4j.PropertyConfigurator.parseCategory(PropertyConfigurator.java:768) at org.apache.log4j.PropertyConfigurator.configureRootCategory(PropertyConfigurator.java:648) at org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:514) at org.apache.log4j.PropertyConfigurator.doConfigure(PropertyConfigurator.java:580) at org.apache.log4j.helpers.OptionConverter.selectAndConfigure(OptionConverter.java:526) at org.apache.log4j.LogManager.(LogManager.java:127) at org.apache.log4j.Logger.getLogger(Logger.java:117) at awg.adb.producer.ProducerDebug.(ProducerDebug.java:13) at awg.adb.producer.ProducerDebug.main(ProducerDebug.java:9) Caused by: java.io.IOException: Wire format negotiation timeout: peer did not send his wire format. at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:98) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68) at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81) at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1387) ... 17 more

我尝试了很多东西，但我不明白为什么会出现这个错误。

参考：我正在使用 - ActiveMQ 5.12.1 - Log4j 1.2.17

Answer 1

是的，如果级别是调试，这是由于 AMQ 日志，一种解决方案是像这样执行相反的操作：

log4j.rootLogger=INFO, stdout

## Be sure that ActiveMQ messages are not logged to 'jms' appender
log4j.logger.org.apache=INFO, stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %-5p %c - %m%n

## Configure 'jms' appender. You'll also need jndi.properties file in order to make it work
log4j.appender.jms=org.apache.log4j.net.JMSAppender
log4j.appender.jms.InitialContextFactoryName=org.apache.activemq.jndi.ActiveMQInitialContextFactory
log4j.appender.jms.ProviderURL=tcp://localhost:61616
log4j.appender.jms.TopicBindingName=logTopic
log4j.appender.jms.TopicConnectionFactoryBindingName=ConnectionFactory
log4j.appender.jms.Threshold=DEBUG
log4j.logger.your.package=jms

将 log4j JMSAppender 与 ActiveMQ 结合使用 - 调试级别的有线格式超时（客户端）

Using log4j JMSAppender with ActiveMQ - wire format timeout in debug level (client side)

java

logging

activemq

log4j

appender