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

[LTS] qpid proton cpp client and LVQ, duplicate acks and messages

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • None
    • AMQ 7.8.1.GA
    • None
    • False
    • False
    • +
    • Undefined
    • Hide

      1. compile projects:

      $ cd proton-cpp-producer/
$ ./compile.

$ cd proton-cpp-consumer/
$ ./compile.sh

      2. Edit broker config for exampleQueue LVQ as shown in description

      3. Run consumer

      $ ./proton-consumer

      4. Run producer

      $ ./proton-producer
      Show
      1. compile projects: $ cd proton-cpp-producer/ $ ./compile. $ cd proton-cpp-consumer/ $ ./compile.sh 2. Edit broker config for exampleQueue LVQ as shown in description 3. Run consumer $ ./proton-consumer 4. Run producer $ ./proton-producer

      In the attached cpp producer/consumer, the following message is observed:

      amqp:internal-error: Unrecoverable error: AMQ119007: error acknowledging message AMQPStandardMessage( [durable=false, messageID=90, address=exampleQueue, size=94, applicationProperties={MESSAGE_KEY=1, MESSAGE_NUMBER=70, SUBJECT=bv.quote.1.id}, properties=Properties{messageId=null, userId=null, to='null', subject='null', replyTo='null', correlationId=null, contentType=null, contentEncoding=null, absoluteExpiryTime=null, creationTime=null, groupId='null', groupSequence=null, replyToGroupId='null'}, extraProperties = TypedProperties[_AMQ_AD=exampleQueue]], Cannot find ref to ack 90

      In addition, even when the message is not observed, duplicate messages are received by the client with the following queue configuration:

      
    <address-settings>
         <address-setting match="exampleQueue">
            <last-value-queue>true</last-value-queue>
         </address-setting>
         ...
    </address-settings>

    <addresses>
            ...
            <multicast>
                <queue name="test1" last-value-key="MESSAGE_KEY" non-destructive="true"/>
            </multicast>
        </address>
      </addresses>

              rhn-support-jbertram Justin Bertram
              rhn-support-shiggs Stephen Higgs
              Roman Vais Roman Vais (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: