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

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

    XMLWordPrintable

Details

    • Bug
    • Status: Closed
    • Major
    • Resolution: Done
    • AMQ 7.8.1.GA
    • None
    • None
    • 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
    • +

    Description

      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>
      

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: