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
    • 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. reproducer2.zip
          13 kB
        2. reproducer.zip
          10 kB
        3. activemq.xml
          5 kB

              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: