Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-836

Messages successfully sent by NMS OpenWire to 7.0.z broker cannot be consumed on 6.3.0 by activemq:consumer

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Blocker
    • None
    • AMQ 7.0.2.GA
    • None
    • None
    • AMQ Broker 7.1 Sprint 2

    Description

      10 messages from 6.3.0-283 activemq:producer -> successfully received at queue TEST002 on 7.0.2 broker -> successfully received at 6.3.0-283 activemq:consumer

      However

      10 messages from NMS 1.7.2 producer -> successfully received at queue TEST001 on 7.0.2 broker -> 6.3.0-283 activemq:consumer fails to receive and throws exception:

      JBossA-MQ:karaf@root> activemq:consumer --brokerUrl tcp://localhost:61616 --user admin --password admin --destination queue://TEST001 --messageCount 5 --sleep 1000
      java.lang.NullPointerException
              at org.apache.activemq.command.MessageId.toString(MessageId.java:140)
              at java.lang.String.valueOf(String.java:2994)
              at java.lang.StringBuffer.append(StringBuffer.java:263)
              at org.apache.activemq.util.IntrospectionSupport.appendToString(IntrospectionSupport.java:330)
              at org.apache.activemq.util.IntrospectionSupport.toString(IntrospectionSupport.java:317)
              at org.apache.activemq.command.BaseCommand.toString(BaseCommand.java:73)
              at org.apache.activemq.command.Message.toString(Message.java:838)
              at org.apache.activemq.command.ActiveMQTextMessage.toString(ActiveMQTextMessage.java:202)
              at java.lang.String.valueOf(String.java:2994)
              at java.lang.StringBuffer.append(StringBuffer.java:263)
              at org.apache.activemq.util.IntrospectionSupport.appendToString(IntrospectionSupport.java:330)
              at org.apache.activemq.util.IntrospectionSupport.toString(IntrospectionSupport.java:317)
              at org.apache.activemq.command.BaseCommand.toString(BaseCommand.java:73)
              at org.apache.activemq.command.BaseCommand.toString(BaseCommand.java:69)
              at java.lang.String.valueOf(String.java:2994)
              at java.lang.StringBuilder.append(StringBuilder.java:131)
              at org.apache.activemq.ActiveMQMessageConsumer.dequeue(ActiveMQMessageConsumer.java:503)
              at org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:636)
              at org.apache.activemq.util.ConsumerThread.run(ConsumerThread.java:62)
      

      See attached 6.3.0 amq.log.2.gz and 7.0.2 artemis.log.gz

      Attachments

        1. amq.log.2.gz
          52 kB
        2. amq-broker-7.0.2-broker0-data.tgz
          25 kB
        3. artemis.log.gz
          12 kB

        Issue Links

          Activity

            People

              rh-ee-ataylor Andy Taylor
              rhn-support-rkieley Roderick Kieley
              Petra Svobodova Petra Svobodova (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: