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

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

      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

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

            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

              Created:
              Updated:
              Resolved: