You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Bosco <jo...@gmail.com> on 2015/07/08 08:28:12 UTC
Active MQ Message Processing Failed
Hi ,I am sending multiple text messages in a loop which sends around 5000
test messages one by one.After sometime the active MQ drops few messages by
throwing the below error.It does not process all the messages and few
messages were not processed due to the following error.Please someone can
help me to resolve this ?Error Log :==========2015-07-08 11:51:51,926 ERROR
[STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) Exception in thread
"ActiveMQ Transport: tcp:///127.0.0.1:62765" 2015-07-08 11:51:51,926 ERROR
[STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
java.lang.ArrayIndexOutOfBoundsException: -240642015-07-08 11:51:51,928
ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.openwire.OpenWireFormat.getFromUnmarshallCache(OpenWireFormat.java:542)2015-07-08
11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.openwire.v3.BaseDataStreamMarshaller.tightUnmarsalCachedObject(BaseDataStreamMarshaller.java:149)2015-07-08
11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.openwire.v3.TransactionInfoMarshaller.tightUnmarshal(TransactionInfoMarshaller.java:71)2015-07-08
11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:362)2015-07-08
11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:276)2015-07-08
11:51:51,935 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:203)2015-07-08
11:51:51,935 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:195)2015-07-08
11:51:51,935 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)2015-07-08
11:51:51,942 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
java.lang.Thread.run(Thread.java:745)
--
View this message in context: http://activemq.2283324.n4.nabble.com/Active-MQ-Message-Processing-Failed-tp4698776.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Active MQ Message Processing Failed
Posted by Tim Bain <tb...@alumni.duke.edu>.
Art, is there a known issue with the cacheEnabled URI option that would
make you expect it to change this behavior? Or are you suggesting it
simply because it will change what gets written to the wire and so it might
avoid whatever bug might be causing this behavior? Either is fine
(especially if it works), I'm just curious what it was that made you think
of that as a possible solution.
Tim
On Jul 8, 2015 2:43 PM, "artnaseef" <ar...@artnaseef.com> wrote:
> I agree on the versions - first match the client and broker version and see
> if that helps. Running with the latest too is a good idea to make sure
> this
> isn't a bug that was already fixed.
>
> With that said, one workaround that may help here - disable the cache
> feature in the protocol (it helps by reducing the size of messages when the
> same information is sent many times, such as producer ID).
>
> The setting is called "cacheEnabled". See the following page for more
> information: http://activemq.apache.org/configuring-wire-formats.html
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Active-MQ-Message-Processing-Failed-tp4698776p4698829.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
Re: Active MQ Message Processing Failed
Posted by artnaseef <ar...@artnaseef.com>.
I agree on the versions - first match the client and broker version and see
if that helps. Running with the latest too is a good idea to make sure this
isn't a bug that was already fixed.
With that said, one workaround that may help here - disable the cache
feature in the protocol (it helps by reducing the size of messages when the
same information is sent many times, such as producer ID).
The setting is called "cacheEnabled". See the following page for more
information: http://activemq.apache.org/configuring-wire-formats.html
--
View this message in context: http://activemq.2283324.n4.nabble.com/Active-MQ-Message-Processing-Failed-tp4698776p4698829.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Active MQ Message Processing Failed
Posted by Christopher Shannon <ch...@gmail.com>.
Which version of the broker and client are you using? If you are using an
older version of the broker or the client you could try updating to newer
versions to see if the problem still exists.
If you are using the newest versions, are you able to reproduce this issue
in a unit test or test case? If so can you should create a new Jira and
attach the test case.
On Wed, Jul 8, 2015 at 2:28 AM, Bosco <jo...@gmail.com> wrote:
> Hi ,I am sending multiple text messages in a loop which sends around 5000
> test messages one by one.After sometime the active MQ drops few messages by
> throwing the below error.It does not process all the messages and few
> messages were not processed due to the following error.Please someone can
> help me to resolve this ?Error Log :==========2015-07-08 11:51:51,926 ERROR
> [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) Exception in thread
> "ActiveMQ Transport: tcp:///127.0.0.1:62765" 2015-07-08 11:51:51,926 ERROR
> [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> java.lang.ArrayIndexOutOfBoundsException: -240642015-07-08 11:51:51,928
> ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765) at
>
> org.apache.activemq.openwire.OpenWireFormat.getFromUnmarshallCache(OpenWireFormat.java:542)2015-07-08
> 11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
>
> org.apache.activemq.openwire.v3.BaseDataStreamMarshaller.tightUnmarsalCachedObject(BaseDataStreamMarshaller.java:149)2015-07-08
> 11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
>
> org.apache.activemq.openwire.v3.TransactionInfoMarshaller.tightUnmarshal(TransactionInfoMarshaller.java:71)2015-07-08
> 11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
>
> org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:362)2015-07-08
> 11:51:51,934 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
>
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:276)2015-07-08
> 11:51:51,935 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
>
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:203)2015-07-08
> 11:51:51,935 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
>
> org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:195)2015-07-08
> 11:51:51,935 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
>
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:183)2015-07-08
> 11:51:51,942 ERROR [STDERR] (ActiveMQ Transport: tcp:///127.0.0.1:62765)
> at
> java.lang.Thread.run(Thread.java:745)
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Active-MQ-Message-Processing-Failed-tp4698776.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.