ExchangePattern.InOut ActiveMq exception

[Joe White]

In Camel 1.5 when using the ExchangePattern.InOut I get an exception
when tearing down the activemq broker the exception occurs no matter how
the thread is stopped. Is there configuration to allow the InOut pattern
to work without causing exceptions when the broker is shut-down? The
exception received at shutdown is below along with the spring config for
the my current activemq setup.

 

Thanks

Joe

 

16:47:00,284 INFO  [AdvisoryConsumer] (ActiveMQ Connection Worker:
tcp://localhost/127.0.0.1:61616) Failed to send remove command:
javax.jms.JMSException: Channel was inactive for too long:
localhost/127.0.0.1:61616

javax.jms.JMSException: Channel was inactive for too long:
localhost/127.0.0.1:61616

      at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.
java:62)

... 

org.springframework.jms.listener.AbstractJmsListeningContainer.refreshSh
aredConnection(AbstractJmsListeningContainer.java:385)

      at
org.springframework.jms.listener.SimpleMessageListenerContainer.onExcept
ion(SimpleMessageListenerContainer.java:206)

      at
org.apache.activemq.ActiveMQConnection$4.run(ActiveMQConnection.java:177
9)

      ...

Caused by: org.apache.activemq.transport.InactivityIOException: Channel
was inactive for too long: localhost/127.0.0.1:61616

      at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor
.java:225)

      at
org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.jav
a:83)

      at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNego
tiator.java:100)

      at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:
40)

      at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelat
or.java:60)

      at
org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnect
ion.java:1214)

      ... 10 more

 

 

 

      <bean id="activemq"
class="org.apache.camel.component.jms.JmsComponent">

            <property name="connectionFactory">

                  <bean
class="org.apache.activemq.spring.ActiveMQConnectionFactory">

                        <property name="brokerURL"
value="tcp://localhost:61616?wireFormat.maxInactivityDuration=0" />

                        <property name="closeTimeout" value="0"/>

                  </bean>

            </property>

      </bean>

      

      <broker:broker useJmx="false" persistent="false"
brokerName="localhost">

        <broker:transportConnectors>

            <broker:transportConnector name="tcp"
uri="tcp://localhost:61616"/>

        </broker:transportConnectors>

    </broker:broker>