The structure of our software is C/S. The Activemq server is included in our
server.
ActiveMQ veriosn is 4.0
Sometimes the exception occurs such as the following stack information when
system is sending a great lot of messages .
The message channel was broken
------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
The message server log as follows
Exception in thread "ActiveMQ Transport: tcp://omchost/189.22.100.15:61616"
java.lang.ClassCastException: org.apache.activemq.command.ProducerId
at
org.apache.activemq.openwire.v1.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:61)
at
org.apache.activemq.openwire.v1.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:65)
at
org.apache.activemq.openwire.v1.ActiveMQObjectMessageMarshaller.tightUnmarshal(ActiveMQObjectMessageMarshaller.java:65)
at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:346)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:272)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:142)
at java.lang.Thread.run(Thread.java:595)
------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
The message client log as follows
Exception in thread "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616"
java.lang.IllegalArgumentException: Invalid version: 167837696, could not
load org.apache.activemq.openwire.v167837696.MarshallerFactory
at
org.apache.activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:325)
at
org.apache.activemq.openwire.OpenWireFormat.renegociatWireFormat(OpenWireFormat.java:565)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:100)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
Caused by: java.lang.ClassNotFoundException:
org.apache.activemq.openwire.v167837696.MarshallerFactory
at
org.apache.activemq.util.ClassLoading.loadClass(ClassLoading.java:104)
at
org.apache.activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:323)
... 6 more
Exception in thread "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616"
java.lang.IllegalArgumentException: Invalid version: 167837696, could not
load org.apache.activemq.openwire.v167837696.MarshallerFactory
at
org.apache.activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:325)
at
org.apache.activemq.openwire.OpenWireFormat.renegociatWireFormat(OpenWireFormat.java:565)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:100)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
Caused by: java.lang.ClassNotFoundException:
org.apache.activemq.openwire.v167837696.MarshallerFactory
at
org.apache.activemq.util.ClassLoading.loadClass(ClassLoading.java:104)
at
org.apache.activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:323)
... 6 more
Exception in thread "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616"
java.lang.IllegalArgumentException: Invalid version: 167837696, could not
load org.apache.activemq.openwire.v167837696.MarshallerFactory
at
org.apache.activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:325)
at
org.apache.activemq.openwire.OpenWireFormat.renegociatWireFormat(OpenWireFormat.java:565)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:100)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
Caused by: java.lang.ClassNotFoundException:
org.apache.activemq.openwire.v167837696.MarshallerFactory
at
org.apache.activemq.util.ClassLoading.loadClass(ClassLoading.java:104)
at
org.apache.activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:323)
... 6 more
--
View this message in context:
http://www.nabble.com/Broken-when-sending-lots-of-messages-tf2342336.html#a6519490
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
