Hi

Could you create a small sample application that demonstrates this?
Will help while investigating.


On Fri, Feb 27, 2009 at 12:59 AM, Joe White <joe.wh...@recondotech.com> wrote:
> 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>
>
>



-- 
Claus Ibsen
Apache Camel Committer

Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/

Reply via email to