failed to delivered acknowledgements even wireFormat.maxInactivityDuration=0 is set

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

failed to delivered acknowledgements even wireFormat.maxInactivityDuration=0 is set

mouser
This post has NOT been accepted by the mailing list yet.
Got the following stack trace in the ActiveMQ client. Broker is good and is never affected. I have added 'wireFormat.maxInactivityDuration=0' but that doesn't seem to help. Looks like the client is sending acknowledgement but when it flushes the message out to the TCP, it got exception because the connection/channel is no longer there. Any workaround?


brokerUrl=failover://(tcp://kramqprod01:61616,tcp://kramqprod01:61616?wireFormat.maxInactivityDuration=0)?randomize=false&maxReconnectAttempts=15


11:40:00.793 [pool-13-thread-1]  ERROR o.a.a.ActiveMQMessageConsumer - ID:hkkrapps02.eclipseoptions.com-43246-1343691002112-0:3:1:1 failed to delivered acknowledgements
javax.jms.JMSException: Channel was inactive for too long: kramqprod01/10.2.50.96:61616
        at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
        at org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1245)
        at org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1237)
        at org.apache.activemq.ActiveMQSession.asyncSendPacket(ActiveMQSession.java:1857)
        at org.apache.activemq.ActiveMQSession.sendAck(ActiveMQSession.java:2022)
        at org.apache.activemq.ActiveMQMessageConsumer$4.run(ActiveMQMessageConsumer.java:703)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
        at java.util.concurrent.FutureTask.run(FutureTask.java:138)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:619)
Caused by: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: kramqprod01/10.2.50.96:61616
        at org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:235)
        at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:83)
        at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104)
        at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
        at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
        at org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1243)
        ... 10 common frames omitted