Hello, I am running apache-activemq-5.1.0 under Centos 5.2 and having the
exact same issue - I was under the assumption (from the posts in this tread)
that this was fixed....just reporting....Thank you!
Exception in thread "ActiveMQ Transport: tcp://localhost/127.0.0.1:61616"
java.lang.ClassCastException: org.apache.activemq.command.BrokerId cannot be
cast to org.apache.activemq.command.ConsumerId
at
org.apache.activemq.openwire.v3.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:71)
at
org.apache.activemq.openwire.v3.ActiveMQMessageMarshaller.tightUnmarshal(ActiveMQMessageMarshaller.java:67)
at
org.apache.activemq.openwire.v3.ActiveMQBytesMessageMarshaller.tightUnmarshal(ActiveMQBytesMessageMarshaller.java:67)
at
org.apache.activemq.openwire.OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:453)
at
org.apache.activemq.openwire.v3.BaseDataStreamMarshaller.tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:126)
at
org.apache.activemq.openwire.v3.MessageDispatchMarshaller.tightUnmarshal(MessageDispatchMarshaller.java:72)
at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:362)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:276)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:203)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:195)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)
at java.lang.Thread.run(Thread.java:619)
this is what i get on shutting the app down:
Oct 9, 2008 4:40:08 PM quickfix.mina.SessionConnector logoutAllSessions
INFO: Logging out all sessions
JMSException=org.apache.activemq.ConnectionFailedException: The JMS
connection has failed: Channel was inactive for too long:
localhost/127.0.0.1:61616
Ramit Arora wrote:
>
> Thanks Rob, I am looking forward to it.
>
> rajdavies wrote:
>>
>> We are currently going through votes on 5.1 - should be a few days
>>
>> cheers,
>>
>> Rob
>> On 16 Apr 2008, at 07:44, Ramit Arora wrote:
>>
>>>
>>> Hey Rob,
>>> Thanks for the reply. BTW, when do you expect to roll out 5.1? We
>>> really
>>> need it due to this bug & NFS based master/slave which is broken in
>>> 5.0.
>>>
>>> Thanks,
>>> Ramit
>>>
>>> rajdavies wrote:
>>>>
>>>> Hi Ramit,
>>>>
>>>> only just saw you stack trace - this is a known problem - caused by a
>>>> bug in the InactivityMonitor - its fixed in the upcoming 5.1 release
>>>> (you could test the release candidate - here:
>>>> http://people.apache.org/~chirino/staging-repos/activemq-5.1.0-RC3/org/apache/activemq/apache-activemq/5.1.0/)
>>>>
>>>> cheers,
>>>>
>>>> Rob
>>>>
>>>>
>>>> On 16 Apr 2008, at 07:03, Ramit Arora wrote:
>>>>>
>>>>> Hey Fred,
>>>>> The problem seems to be a bit strange. It occurs only if I use
>>>>> Solaris to
>>>>> host my broker. The problem is much more frequent if the server
>>>>> machine is
>>>>> Solaris/x86 rather than Solaris/Sparc. Windows machines are not
>>>>> suffering
>>>>> from this problem. And the problem disappears if i use JNDI to set
>>>>> my
>>>>> connection factories & destinations. Pretty weird!
>>>>>
>>>>> Thanks,
>>>>> Ramit
>>>>>
>>>>> Fred D wrote:
>>>>>>
>>>>>> Maybe try to see where the thresold is ... increase 1 or 2
>>>>>> subsribers
>>>>>> until it happens.
>>>>>>
>>>>>> A workaround might be to try a network of 2 brokers perhaps to see
>>>>>> if its
>>>>>> a scaling issue.
>>>>>>
>>>>>> Fred
>>>>>>
>>>>>>
>>>>>> Ramit Arora wrote:
>>>>>>>
>>>>>>> Hi,
>>>>>>> I am testing ActiveMQ 5.0 using a Perl Publisher (using
>>>>>>> Net::Stomp) &
>>>>>>> Java Subscribers (Openwire). It works well when the number of
>>>>>>> subscribers
>>>>>>> is low (1 or 2) but when I increase the number of subscribers to
>>>>>>> around
>>>>>>> 10, I face the following problem:
>>>>>>>
>>>>>>> A subscriber shows the following stack trace
>>>>>>> Exception in thread "ActiveMQ Transport:
>>>>>>> tcp://xx.yy.zz.com/nnn.nn.nnn.nn:61616"
>>>>>>> java.lang.ClassCastException:
>>>>>>> org.apache.activemq.command.BrokerId can not be cast to
>>>>>>> org.apache.activemq.command.ConsumerId
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3.MessageMarshaller.tightUnmarshal(MessageMarshaller.java:71)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .ActiveMQMessageMarshaller
>>>>>>> .tightUnmarshal(ActiveMQMessageMarshaller.java:67)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .ActiveMQTextMessageMarshaller
>>>>>>> .tightUnmarshal(ActiveMQTextMessageMarshaller.java:67)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .OpenWireFormat.tightUnmarshalNestedObject(OpenWireFormat.java:
>>>>>>> 452)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .BaseDataStreamMarshaller
>>>>>>> .tightUnmarsalNestedObject(BaseDataStreamMarshaller.java:127)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .MessageDispatchMarshaller
>>>>>>> .tightUnmarshal(MessageDispatchMarshaller.java:72)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:
>>>>>>> 361)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:
>>>>>>> 275)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .transport.tcp.TcpTransport.readCommand(TcpTransport.java:
>>>>>>> 192)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:184)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
>>>>>>> 172)
>>>>>>> at java.lang.Thread.run(Thread.java:619)
>>>>>>>
>>>>>>> The broker shows the following stack trace:
>>>>>>> Exception in thread "ActiveMQ Connection Dispatcher: /
>>>>>>> nnn.nn.nn.nn:
>>>>>>> 39997"
>>>>>>> java.lang.NullPointerException
>>>>>>> at java.lang.System.arraycopy(Native Method)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .transport
>>>>>>> .tcp.TcpBufferedOutputStream.write(TcpBufferedOutputStream.java:
>>>>>>> 89)
>>>>>>> at java.io.DataOutputStream.write(DataOutputStream.java:90)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .BaseDataStreamMarshaller
>>>>>>> .tightMarshalByteSequence2(BaseDataStreamMarshaller.java:433)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3.MessageMarshaller.tightMarshal2(MessageMarshaller.java:173)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .ActiveMQMessageMarshaller
>>>>>>> .tightMarshal2(ActiveMQMessageMarshaller.java:90)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .ActiveMQTextMessageMarshaller
>>>>>>> .tightMarshal2(ActiveMQTextMessageMarshaller.java:90)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .OpenWireFormat.tightMarshalNestedObject2(OpenWireFormat.java:423)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .BaseDataStreamMarshaller
>>>>>>> .tightMarshalNestedObject2(BaseDataStreamMarshaller.java:137)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .openwire
>>>>>>> .v3
>>>>>>> .MessageDispatchMarshaller
>>>>>>> .tightMarshal2(MessageDispatchMarshaller.java:106)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq.openwire.OpenWireFormat.marshal(OpenWireFormat.java:238)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:153)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .transport.InactivityMonitor.oneway(InactivityMonitor.java:157)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq.transport.TransportFilter.oneway(TransportFilter.java:
>>>>>>> 82)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:
>>>>>>> 91)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .broker.TransportConnection.dispatch(TransportConnection.java:
>>>>>>> 1151)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .broker
>>>>>>> .TransportConnection.processDispatch(TransportConnection.java:766)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .broker.TransportConnection.iterate(TransportConnection.java:801)
>>>>>>> at
>>>>>>> org
>>>>>>> .apache
>>>>>>> .activemq
>>>>>>> .thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
>>>>>>> at
>>>>>>> org.apache.activemq.thread.DedicatedTaskRunner
>>>>>>> $1.run(DedicatedTaskRunner.java:36)
>>>>>>>
>>>>>>> The broker & the subscriber keep running after this, but the
>>>>>>> broker does
>>>>>>> not deliver messages to that subscriber. Other subscribers work
>>>>>>> fine.
>>>>>>> This problem is repeatedly occuring. I am using SunOS 5.10 on a
>>>>>>> machine
>>>>>>> with 8 processors & 32 GB of RAM.
>>>>>>> Please help!
>>>>>>>
>>>>>>> TIA,
>>>>>>> Ramit
>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>
>>>>>>
>>>>>
>>>>> --
>>>>> View this message in context:
>>>>> http://www.nabble.com/Null-Pointer-Exception-on-broker-tp16048936s2354p16717003.html
>>>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>>>
>>>>
>>>>
>>>>
>>>
>>> --
>>> View this message in context:
>>> http://www.nabble.com/Null-Pointer-Exception-on-broker-tp16048936s2354p16717433.html
>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>
>>
>>
>>
>
>
--
View this message in context:
http://www.nabble.com/Null-Pointer-Exception-on-broker-tp16048936p19907073.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
