[AMQ-2605] Unexpected error occured on TcpTransport caused by ClassCastException

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Cannot Reproduce
• Affects Version/s: 5.3.0
• Fix Version/s: 5.x
• Assignee: Unassigned
• Reporter: Mario Lukica
• Created: 15/Feb/10 09:06
• Updated: 14/Oct/11 22:42
• Resolved: 14/Oct/11 22:42

Description

In setup with 2 brokers connected with ConduitBridge, we have a problem with network connector which is every couple of days disconnected because of ClassCastException on TcpTransport on other node.
Network connector reconnects after some time (cca 1 min), but we have some minor message loss since we use syncSend=false on queues.

• node1:

  15:07:59,160 DEBUG [Transport           ] Transport failed: java.io.IOException: Unexpected error occured
  java.io.IOException: Unexpected error occured
          at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:192)
          at java.lang.Thread.run(Thread.java:619)
  Caused by: java.lang.ClassCastException
  15:07:59,219 DEBUG [TransportConnection ] Stopping connection: /192.168.0.2:34586
  15:07:59,220 DEBUG [TransportConnection ] Stopped transport: /192.168.0.2:34586
  

• node2:

  15:08:48,564 WARN  [DemandForwardingBridge] Network connection between vm://broker02#1569160 and tcp://node1/192.168.0.1:62616 shutdown due to a remote error: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: node1/192.168.0.1:62616
  15:08:48,565 DEBUG [DemandForwardingBridge] The remote Exception was: org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: node1/192.168.0.1:62616
  org.apache.activemq.transport.InactivityIOException: Channel was inactive for too long: node1/192.168.0.1:62616
          at org.apache.activemq.transport.InactivityMonitor$4.run(InactivityMonitor.java:168)
          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)
  15:08:48,566 DEBUG [DemandForwardingBridge]  stopping broker02 bridge to broker01