activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From grant <xomcc...@yahoo.com.cn>
Subject Broken when sending lots of messages
Date Wed, 27 Sep 2006 02:34:19 GMT

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.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message