Re: ExchangePattern.InOut ActiveMq exception

2009-02-28 Thread Claus Ibsen
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/


ExchangePattern.InOut ActiveMq exception

2009-02-26 Thread 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