WireFormatNegotiator.java
public void oneway(Object command) throws IOException {
try {
if( !readyCountDownLatch.await(negotiateTimeout,
TimeUnit.MILLISECONDS) )
throw new IOException("Wire format negociation timeout: peer
did not send his wire format.");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
throw new InterruptedIOException();
}
super.oneway(command);
}
@@@@
About more:
read:
http://www.nabble.com/ActiveMQConnection%3AonAsyncException-td14316770s2354.html
@@@@
i tested under below envirment:
JAVA:
java version "1.5.0_06"
Java(TM) 2 Runtime Environment, Standard Edition (build 1.5.0_06-b05)
Java HotSpot(TM) Client VM (build 1.5.0_06-b05, mixed mode)
OS:
Linux version 2.4.21-4.EL ([EMAIL PROTECTED]) (gcc version
3.2.3 20030502 (Red Hat Linux 3.2.3-20)) #1 Fri Oct 3 18:13:58 EDT 2003
and
Linux version 2.4.21-4.ELsmp ([EMAIL PROTECTED]) (gcc version
3.2.3 20030502 (Red Hat Linux 3.2.3-20)) #1 SMP Fri Oct 3 17:31:21 EDT 2003
Linux version 2.4.21-4.ELsmp ([EMAIL PROTECTED]) (gcc version
3.2.3 20030502 (Red Hat Linux 3.2.3-20)) #1 SMP Fri Oct 3 17:31:21 EDT 2003
Error encountered,will handle exception.Channel was inactive for too long:
/10.61.0.212:61616
javax.jms.JMSException: Channel was inactive for too long:
/10.61.0.212:61616
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
at
org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1642)
at
org.apache.activemq.ActiveMQConnection.onException(ActiveMQConnection.java:1659)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:98)
at
org.apache.activemq.transport.ResponseCorrelator.onException(ResponseCorrelator.java:116)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:98)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:98)
at
org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:143)
at
org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:169)
at
org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:108)
Caused by: org.apache.activemq.transport.InactivityIOException: Channel was
inactive for too long: /10.61.0.212:61616
... 1 more
javax.jms.JMSException: java.io.InterruptedIOException
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1183)
at
org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1262)
at
org.apache.activemq.ActiveMQConnection.setClientID(ActiveMQConnection.java:372)
at
org.gos.common.msg.controller.MessageConsumerWrapper.handleException(MessageConsumerWrapper.java:86)
at
org.gos.common.msg.controller.MessageConsumerWrapper.access$0(MessageConsumerWrapper.java:71)
at
org.gos.common.msg.controller.MessageConsumerWrapper$3.onException(MessageConsumerWrapper.java:121)
at
org.apache.activemq.ActiveMQConnection$3.run(ActiveMQConnection.java:1648)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Thread.java:595)
Caused by: java.io.InterruptedIOException
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:89)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:70)
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:75)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1172)
... 9 more
--
View this message in context:
http://www.nabble.com/is-this-a-bug--tp14411503s2354p14411503.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
