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

Question

我在尝试用log4j JMSappender和ActiveMQ做一个POC。我成功地效仿了这个例子-

但这是信息级的。我做了一些修改以在调试级别使用它，我的程序和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：错误 激活名为 [jms] 的追加器的选项时出错。javax.jms.JMS例外：连线格式协商超时：对等方未发送他的连线格式。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.activemq Connect.createsession（ActiveMQConnection.java：323） at org.apache.activemq.ActiveMQConnection.createTopicSession（ActiveMQ连接.java：1134） atorg.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.java.propertyConfigurator.parsecategory（PropertyConfigurator.java：842） at org.apache.log4j.PropertyConfigurator.parseCategory（属性配置器.java：768） at org.apache.log4j.PropertyConfigurator.configureRootCategory（属性配置器.java：648） at org.apache.log4j.PropertyConfigurator.doConfigure（属性配置器.java：514） at org.apache.log4j.PropertyConfigurator.doConfigure（PropertyConfiator.java：580） at org.apache.log4j.helpers.OptionConverter.selectandConfigure（选项转换器.java：526） at org.apache.log4j.LogManager.（日志管理器.java：127） 在 org.apache.log4j.logger.getLogger（记录器.java：117） 在 awg.adb.producer.producerdebug.（制片人显示.java：13）在 awg.adb.制片人主要（制片人德布格.java：9） 由： java.io.IO异常： 电线格式协商超时： 对等方没有发送他的电线格式.at org.apache.activemq.transport.WireFormatNegotiator.oneway（WireFormatNegotiator.java：98） at org.apache.activemq.transportsport.oneway（互斥传输.java：68） 在 org.apache.activemq.transport.responseCorrelator.asyncRequest（响应相关.java：81） at org.apache.activemq.transportmq.ResponseCorreator.request（响应相关方.java：86） 在 org.apache.activemq.ActiveMQConnection.syncSendPacket（ActiveMQConnection.java：1387） ...另外 17

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

有关信息：我正在使用 - 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