activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Broken when sending lots of messages
Date Wed, 27 Sep 2006 06:51:43 GMT
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 <xomccmox@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/

Mime
View raw message