Uploaded image for project: 'JBoss A-MQ'
  1. JBoss A-MQ
  2. ENTMQ-906

Cannot get JMSXGroupSeq attributes intermittently when the message body size is 100KB.

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Blocker Blocker
    • JBoss A-MQ 6.2.1
    • JBoss A-MQ 6.1
    • amqp
    • None

    • A-MQ 6.1.0.GA + R1 patch + R1P2 patch
      AMQP 1.0 Java Client (Qpid 0.26 and 0.30 are tested)
      activemq.xml (attached to this case)

    • Hide

      You can reproduce this issue with the reproducer.zip.

      1. Start a A-MQ broker with the activemq.xml.
      2. Send 100KB x 10 messages to a queue.

      $ mvn -P producer
      ...
      11:34:45 INFO message body size=102400
      11:34:45 INFO Sending 10 messages
      11:34:46 INFO Closing connection

      3. Receive all messages from the queue and check the JMSXGroupSeq.
      You can see all sequence number 1..10 first time.

      $ mvn -P consumer

      11:34:56 INFO Start consuming messages from org.apache.qpid.amqp_1_0.jms.impl.QueueImpl@bc665ea5 with 10000ms timeout
      11:34:56 INFO Got 1. message: org.apache.qpid.amqp_1_0.jms.impl.BytesMessageImpl@7d8e7369
      11:34:56 INFO — JMSXGroupID=MyApp
      11:34:56 INFO — JMSXGroupSeq=1
      11:34:56 INFO Got 2. message: org.apache.qpid.amqp_1_0.jms.impl.BytesMessageImpl@133b32e5
      11:34:56 INFO — JMSXGroupID=MyApp
      11:34:56 INFO — JMSXGroupSeq=2
      .....

      4. Send 100KB x 10 messages to the queue again.

      $ mvn -P producer

      5. Receive all messages from the queue.
      You see some sequence numbers are nulls because of the messages are AmqpMessageImpls
      not BytesMessageImpls.

      11:35:35 INFO Start consuming messages from org.apache.qpid.amqp_1_0.jms.impl.QueueImpl@bc665ea5 with 10000ms timeout
      org.apache.qpid.amqp_1_0.type.AmqpErrorException
      at org.apache.qpid.amqp_1_0.codec.ValueHandler.readConstructor(ValueHandler.java:133)
      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)
      .....

      Show
      You can reproduce this issue with the reproducer.zip. 1. Start a A-MQ broker with the activemq.xml. 2. Send 100KB x 10 messages to a queue. $ mvn -P producer ... 11:34:45 INFO message body size=102400 11:34:45 INFO Sending 10 messages 11:34:46 INFO Closing connection 3. Receive all messages from the queue and check the JMSXGroupSeq. You can see all sequence number 1..10 first time. $ mvn -P consumer 11:34:56 INFO Start consuming messages from org.apache.qpid.amqp_1_0.jms.impl.QueueImpl@bc665ea5 with 10000ms timeout 11:34:56 INFO Got 1. message: org.apache.qpid.amqp_1_0.jms.impl.BytesMessageImpl@7d8e7369 11:34:56 INFO — JMSXGroupID=MyApp 11:34:56 INFO — JMSXGroupSeq=1 11:34:56 INFO Got 2. message: org.apache.qpid.amqp_1_0.jms.impl.BytesMessageImpl@133b32e5 11:34:56 INFO — JMSXGroupID=MyApp 11:34:56 INFO — JMSXGroupSeq=2 ..... 4. Send 100KB x 10 messages to the queue again. $ mvn -P producer 5. Receive all messages from the queue. You see some sequence numbers are nulls because of the messages are AmqpMessageImpls not BytesMessageImpls. 11:35:35 INFO Start consuming messages from org.apache.qpid.amqp_1_0.jms.impl.QueueImpl@bc665ea5 with 10000ms timeout org.apache.qpid.amqp_1_0.type.AmqpErrorException at org.apache.qpid.amqp_1_0.codec.ValueHandler.readConstructor(ValueHandler.java:133) 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) .....

      When I try to send more than 100KB sized message, this issue is 100% reproduced on my PC.

      • This issue doesn't happen just after staring the broker.
        Only see the issue after second receiving messages.
      • This issue happens only with large sized messges.
        In 50KB, 100KB, 250KB, 500KB cases but 50KB is only OK for this test.

        1. activemq.xml
          5 kB
          Takayuki Konishi

              tbish@redhat.com Timothy Bish (Inactive)
              rhn-support-tkonishi Takayuki Konishi
              Votes:
              1 Vote for this issue
              Watchers:
              8 Start watching this issue

                Created:
                Updated:
                Resolved: