You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Fred D <fr...@ttmsolutions.com> on 2008/04/15 20:25:57 UTC
Re: Null Pointer Exception on broker
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
>
>
>
-----
Goto www.ttmsolutions.com for a free ActiveMQ user guide
--
View this message in context: http://www.nabble.com/Null-Pointer-Exception-on-broker-tp16048936s2354p16703624.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Null Pointer Exception on broker
Posted by Iakov <ad...@jbpcapital.com>.
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.
Re: Null Pointer Exception on broker
Posted by Ramit Arora <ra...@gmail.com>.
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-tp16048936s2354p16720985.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Null Pointer Exception on broker
Posted by Rob Davies <ra...@gmail.com>.
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.
>
Re: Null Pointer Exception on broker
Posted by Ramit Arora <ra...@gmail.com>.
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.
Re: Null Pointer Exception on broker
Posted by Rob Davies <ra...@gmail.com>.
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.
>
Re: Null Pointer Exception on broker
Posted by Ramit Arora <ra...@gmail.com>.
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.