Matt, Thank you for your response and solution. That worked very well.
Paul On Wed, Jan 4, 2017 at 9:43 AM, Matt Sicker <boa...@gmail.com> wrote: > Using ActiveMQ, you can just use the failover transport to automate this: < > http://activemq.apache.org/failover-transport-reference.html>. > > On 4 January 2017 at 09:34, Paul Mooney <pc.mooney+lo...@gmail.com> wrote: > > > Hello, > > > > I am trying to create a logging solution using JMSAppender. The > > JMSAppender is working great and is really a great tool to have. > > The issue I have is when I restart the JMS broker, the logger fails to > > reconnect to the broker. Is there somthing I am missing that can have > the > > logger reconnect to the JMS broker? > > > > Technologies: mulesoft ESB, Apache ActiveMQ > > > > My application log after JMS restart: > > > > 2017-01-04 09:24:00,949 Log4j2-AsyncLoggerConfig-182 ERROR An exception > > occurred processing Appender jmsQueue org.apache.logging.lo > > g4j.core.appender.AppenderLoggingException: > > javax.jms.IllegalStateException: The Session is closed > > at > > org.apache.logging.log4j.core.appender.mom.JmsAppender. > > append(JmsAppender.java:66) > > > > at > > org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender( > > AppenderControl.java:152) > > > > at > > org.apache.logging.log4j.core.config.AppenderControl. > > callAppender0(AppenderControl.java:125) > > > > at > > org.apache.logging.log4j.core.config.AppenderControl. > > callAppenderPreventRecursion(AppenderControl.java:116) > > > > at > > org.apache.logging.log4j.core.config.AppenderControl. > > callAppender(AppenderControl.java:84) > > > > at > > org.apache.logging.log4j.core.config.LoggerConfig. > > callAppenders(LoggerConfig.java:390) > > > > at > > org.apache.logging.log4j.core.async.AsyncLoggerConfig. > asyncCallAppenders( > > AsyncLoggerConfig.java:103) > > > > at > > org.apache.logging.log4j.core.async.AsyncLoggerConfigDisruptor$ > > Log4jEventWrapperHandler.onEvent(AsyncLoggerConfigDisrupt > > or.java:90) > > at > > org.apache.logging.log4j.core.async.AsyncLoggerConfigDisruptor$ > > Log4jEventWrapperHandler.onEvent(AsyncLoggerConfigDisrupt > > or.java:76) > > at > > com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:128) > > at > > java.util.concurrent.ThreadPoolExecutor.runWorker( > > ThreadPoolExecutor.java:1142) > > > > at > > java.util.concurrent.ThreadPoolExecutor$Worker.run( > > ThreadPoolExecutor.java:617) > > > > at java.lang.Thread.run(Thread.java:745) > > Caused by: javax.jms.IllegalStateException: The Session is closed > > at > > org.apache.activemq.ActiveMQSession.checkClosed( > ActiveMQSession.java:771) > > at > > org.apache.activemq.ActiveMQSession.configureMessage( > > ActiveMQSession.java:759) > > > > at > > org.apache.activemq.ActiveMQSession.createTextMessage( > > ActiveMQSession.java:440) > > > > at > > org.apache.logging.log4j.core.appender.mom.JmsManager. > > createMessage(JmsManager.java:120) > > > > at > > org.apache.logging.log4j.core.appender.mom.JmsAppender. > > append(JmsAppender.java:62) > > > > ... 12 more > > > > > > > > My Log4J2.xml properties file: > > > > <JMS name="jmsQueue" > > destinationBindingName="dev.logging" > > factoryName="org.apache.activemq.jndi.ActiveMQInitialContextFactory" > > factoryBindingName="ConnectionFactory" > > providerURL="tcp://<url>:61616?initialReconnectDelay= > > 10000,maxReconnectAttempts=10" > > userName="log" > > password="log"> > > <PatternLayout pattern='{"type":"integration", "app":"logtest", > > "env":"dev", "date":"%d{ISO8601}", "thread":"[%t]", "loglevel":"%-5p", > > "message":"%c - %m"}'/> > > </JMS> > > > > > > > > Thank you for your time. > > Paul > > > > > > -- > Matt Sicker <boa...@gmail.com> > -- This e-mail is: [ ] public [x] private [ ] ask first
