Waylon created AMQ-7173:
---------------------------

             Summary: java.io.IOException: Unknown data type: 0 
                 Key: AMQ-7173
                 URL: https://issues.apache.org/jira/browse/AMQ-7173
             Project: ActiveMQ
          Issue Type: Bug
    Affects Versions: 5.15.3
            Reporter: Waylon


When enabling loggingBrokerPlugin network bridges are shutdown intermittently 
with Unknown data type: 0 exception:
{code:java}
2019-04-01 23:50:12,190 | WARN  | Network connection between vm://amq02#146 and 
tcp://amq00/10.101.16.6:61616@45344 shutdown due to a remote error: {} | 
org.apache.activemq.network.DemandForwardingBridgeSupport | ActiveMQ Transport: 
tcp://amq00/10.101.16.6:61616@45344
java.io.IOException: Unknown data type: 0
    at 
org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:438)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.BaseDataStreamMarshaller.tightUnmarsalCachedObject(BaseDataStreamMarshaller.java:143)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:57)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:66)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.ActiveMQBytesMessageMarshaller.tightUnmarshal(ActiveMQBytesMessageMarshaller.java:66)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:456)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.BaseDataStreamMarshaller.tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:125)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:74)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:66)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:456)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.BaseDataStreamMarshaller.tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:125)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.v12.MessageDispatchMarshaller.tightUnmarshal(MessageDispatchMarshaller.java:71)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:365)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:278)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:240)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:232)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:215)[activemq-client-5.15.3.jar:5.15.3]
    at java.lang.Thread.run(Thread.java:748)[:1.8.0_172]
2019-04-01 23:50:13,190 | INFO  | Establishing network connection from 
vm://amq02 to tcp://amq00:61616 | 
org.apache.activemq.network.DiscoveryNetworkConnector | ActiveMQ Task-6
2019-04-01 23:50:13,218 | WARN  | Failed to add Connection 
id=amq02->amq00-39739-1554157637011-66:1, 
clientId=amq02-to-amq00_amq00_inbound_amq02 due to {} | 
org.apache.activemq.broker.TransportConnection | 
triggerStartAsyncNetworkBridgeCreation: 
remoteBroker=tcp://amq00/10.101.16.6:61616@45350, localBroker= vm://amq02#148
javax.jms.InvalidClientIDException: Broker: amq02 - Client: 
amq02-to-amq00_amq00_inbound_amq02 already connected from vm://amq02#146
    at 
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:247)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.jmx.ManagedRegionBroker.addConnection(ManagedRegionBroker.java:227)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:119)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:99)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:843)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:139)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:330)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:194)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.vm.VMTransport.doDispatch(VMTransport.java:165)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.vm.VMTransport.dispatch(VMTransport.java:157)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:134)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)[activemq-client-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:508)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.network.DemandForwardingBridgeSupport.doStartLocalAndRemoteBridges(DemandForwardingBridgeSupport.java:460)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.network.DemandForwardingBridgeSupport.access$600(DemandForwardingBridgeSupport.java:113)[activemq-broker-5.15.3.jar:5.15.3]
    at 
org.apache.activemq.network.DemandForwardingBridgeSupport$5.run(DemandForwardingBridgeSupport.java:370)[activemq-broker-5.15.3.jar:5.15.3]
    at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)[:1.8.0_172]
    at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)[:1.8.0_172]
    at java.lang.Thread.run(Thread.java:748)[:1.8.0_172]
{code}
 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to