在ActiveMQ中使用log4j JMSAppender - 调试级别（客户端）中的线路格式超时

我试图使用log4j JMSappender和ActiveMQ进行POC。我成功地遵循这个例子 - >http://activemq.apache.org/how-do-i-use-log4j-jms-appender-with-activemq.html 在ActiveMQ中使用log4j JMSAppender - 调试级别（客户端）中的线路格式超时

但这是为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的：错误错误而激活用于附加器命名项[JMS]。 javax.jms.JMSException：有线格式协商超时：对等没有发送他的有线格式。在 org.apache.activemq.util.JMSExceptionSupport.create（JMSExceptionSupport.java:72）在 org.apache.activemq.ActiveMQConnection.syncSendPacket（ActiveMQConnection.java:1412）在 org.apache.activemq.ActiveMQConnection。 ensureConnectionInfoSent（ActiveMQConnection.java:1501）在 org.apache.activemq.ActiveMQConnection.createSession（ActiveMQConnection.java:323）在 org.apache.activemq.ActiveMQConnection.createTopicSession（ActiveMQConnection.java:1134）在有机.apache.log4j.net.JMSAppender.activateOptions（JMSAppender.java:218） at org.apache.log4j.config.PropertySetter.activate（PropertySetter。的java：307）在 org.apache.log4j.config.PropertySetter.setProperties（PropertySetter.java:172）在 org.apache.log4j.config.PropertySetter.setProperties（PropertySetter.java:104）在有机.apache.log4j.PropertyConfigurator.parseAppender（PropertyConfigurator.java:842）在 org.apache.log4j.PropertyConfigurator.parseCategory（PropertyConfigurator.java:768）在 org.apache.log4j.PropertyConfigurator.configureRootCategory（PropertyConfigurator.java ：648） at org.apache.log4j.PropertyConfigurator.doConfigure（PropertyConfigurator.java:514） at org.apache.log4j.PropertyCo nfigurator.doConfigure（PropertyConfigurator.java:580）在 org.apache.log4j.helpers.OptionConverter.selectAndConfigure（OptionConverter.java:526）在org.apache.log4j.LogManager。（LogManager.java:127）在 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 ）原因： java.io.IOException：有线格式协商超时：对方未发送线路格式。在 org.apache.activemq.transport.WireFormatNegotiator.oneway（WireFormatNegotiator.java:98）在 org.apache.activemq.transport.MutexTransport.oneway（MutexTransport.java:68）在 org.apache.activemq。 transport.ResponseCorrelator.asyncRequest（ResponseCorrelator.java:81） at org.apache.activemq.transport.ResponseCorrelator.request（ResponseCorrelator。Java的：86）在 org.apache.activemq.ActiveMQConnection.syncSendPacket（ActiveMQConnection.java:1387） ...... 17多个

我尝试了很多事情，我不明白为什么我有这样的错误。

有关信息：我使用 - ActiveMQ的5.12.1 - Log4j的1.2.17

来源

2017-01-17 ellirar

是的，它是由于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

来源

2017-01-17 13:45:56

感谢哈桑。我尝试了你的例子，通过'log4j.logger.your.package = DEBUG，jms'改变'log4j.logger.your.package = jms'，它的工作。 – ellirar

在ActiveMQ中使用log4j JMSAppender - 调试级别（客户端）中的线路格式超时

回答

相关问题