activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gurinder (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (AMQ-4920) AmqpErrorException occurs with multiple concurrent amqp topic consumers
Date Fri, 28 Mar 2014 19:23:15 GMT

    [ https://issues.apache.org/jira/browse/AMQ-4920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13951265#comment-13951265
] 

Gurinder edited comment on AMQ-4920 at 3/28/14 7:21 PM:
--------------------------------------------------------

Is there a workaround for this bug. I am using qpid-java-amqp-1-0-client-jms-0.26 and still
hit this error.


was (Author: gurilubana):
Is there a workaround for this bug.

> AmqpErrorException occurs with multiple concurrent amqp topic consumers
> -----------------------------------------------------------------------
>
>                 Key: AMQ-4920
>                 URL: https://issues.apache.org/jira/browse/AMQ-4920
>             Project: ActiveMQ
>          Issue Type: Bug
>            Reporter: Kevin Earls
>            Assignee: Kevin Earls
>         Attachments: rp.out
>
>
> I'll add a test to reproduce this.  There are currently 2 problems.  The more frequent
one looks like:  org.apache.qpid.amqp_1_0.type.AmqpErrorException
>         at org.apache.qpid.amqp_1_0.codec.ValueHandler.readConstructor(ValueHandler.java:99)
>         at org.apache.qpid.amqp_1_0.codec.ValueHandler.parse(ValueHandler.java:90)
>         at org.apache.qpid.amqp_1_0.codec.ValueHandler.readConstructor(ValueHandler.java:105)
>         at org.apache.qpid.amqp_1_0.codec.ValueHandler.parse(ValueHandler.java:90)
> … repeated many times
> at org.apache.qpid.amqp_1_0.codec.ValueHandler.readConstructor(ValueHandler.java:105)
>         at org.apache.qpid.amqp_1_0.codec.ValueHandler.parse(ValueHandler.java:90)
>         at org.apache.qpid.amqp_1_0.messaging.SectionDecoderImpl.parseAll(SectionDecoderImpl.java:49)
>         at org.apache.qpid.amqp_1_0.client.Receiver.receive(Receiver.java:280)
>         at org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.receive0(MessageConsumerImpl.java:286)
>         at org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.receiveImpl(MessageConsumerImpl.java:255)
>         at org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.receive(MessageConsumerImpl.java:238)
>         at org.apache.qpid.amqp_1_0.jms.impl.MessageConsumerImpl.receive(MessageConsumerImpl.java:56)
>         at org.apache.activemq.transport.amqp.ENTMQ466ConsumerThread.run(ENTMQ466Test.java:123)
> This occurs at the line "final EncodedMessage amqp = outboundTransformer.transform(jms);"
in the ConsumerContext.pumpOutbound() method of AmqpProtocolConverter(). This call sometimes
returns with its content (amqp.getArray()) set to all zeros. 
> On those messages this line
> LOG.info("In pumpOutbound, setting currentBuffer to offset {} length {} content [{}]",
amqp.getArrayOffset(), amqp.getLength(), amqp.getArray());
> returns:
> 2013-11-26 17:19:16,680 [calhost] Task-3] - INFO AmqpProtocolConverter - In pumpOutbound,
setting currentBuffer to offset 0 length 162 content [[0, 0, 0, 0, 0, \
> 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0,\
> 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0\
> , 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
0, 0, 0, 0, 0, 0, 0, 0, 0]]
> At the root of this, outboundTransformer is a (proton) AutoOutboundTransformer.  It calls
AMQPNativeOutboundTransformer.transform(), which calls msg.readBytes(data), which sometimes
writes all 0s to data.  Here msg is an ActiveMQBytesMessage.  



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message