You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by grant <xo...@yahoo.com.cn> on 2006/09/27 04:34:19 UTC
Broken when sending lots of messages
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.
Re: Broken when sending lots of messages
Posted by blevans <mi...@gmail.com>.
James, any chance you could post a link to some documentation on that bug
fix?
--
View this message in context: http://activemq.2283324.n4.nabble.com/Broken-when-sending-lots-of-messages-tp2348519p4684873.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Broken when sending lots of messages
Posted by James Strachan <ja...@gmail.com>.
I"d recommend you upgrade to 4.0.2 this sounds like a bug that was
fixed some time ago.
On 9/27/06, grant <xo...@yahoo.com.cn> wrote:
>
> 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.
>
>
--
James
-------
http://radio.weblogs.com/0112098/