[
https://issues.apache.org/jira/browse/AMQ-2619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Bish closed AMQ-2619.
-----------------------------
Resolution: Cannot Reproduce
Fix Version/s: (was: 5.6.0)
One like cause of this error could be a network interruption during the time
that the message is being received causing loss of data. Since the sends are
not sync message loss in this case would be expected.
> Transport fails IOException (Unknown data type: 0)
> --------------------------------------------------
>
> Key: AMQ-2619
> URL: https://issues.apache.org/jira/browse/AMQ-2619
> Project: ActiveMQ
> Issue Type: Bug
> Affects Versions: 5.3.0
> Reporter: Goran Pugar
>
> In setup with 2 brokers connected with ConduitBridge, we have a problem with
> network connector which is ocasionally disconnected because of
> java.io.IOException (Unknown data type: 0) on other node - stack trace
> attached below.
> Network connector reconnects after some time, but we have some message loss
> since we use syncSend=false on queues.
> {code}
> 10:33:32,539 DEBUG [Transport ] Transport failed:
> java.io.IOException: Unknown data type: 0
> java.io.IOException: Unknown data type: 0
> at
> org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:441)
> at
> org.apache.activemq.openwire.v5.BaseDataStreamMarshaller.tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:126)
> at
> org.apache.activemq.openwire.v5.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:83)
> at
> org.apache.activemq.openwire.v5.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:66)
> at
> org.apache.activemq.openwire.v5.ActiveMQObjectMessageMarshaller.tightUnmarshal(ActiveMQObjectMessageMarshaller.java:66)
> at
> org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:366)
> at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:279)
> at
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:210)
> at
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:202)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
> at java.lang.Thread.run(Thread.java:619)
> 10:33:32,541 DEBUG [TransportConnection ] Stopping connection:
> /192.168.0.2:40408
> 10:33:32,542 DEBUG [TransportConnection ] Stopped transport:
> /192.168.0.2:40408
> 10:33:32,542 DEBUG [TransportConnection ] Cleaning up connection resources:
> /192.168.0.2:40408
> 10:33:32,542 DEBUG [AbstractRegion ] mgw.broker01 removing consumer:
> ID:node2-42470-1264024561798-1382:0:1:1 for destination:
> topic://ActiveMQ.Advisory.Consumer.>
> 10:33:32,561 DEBUG [TransportConnection ] Connection Stopped:
> /192.168.0.2:40408
> {code}
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
