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

qpid proton cpp client and LVQ, duplicate acks and messages

    XMLWordPrintable

Details

    • 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

    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

          is cloned by

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-4949 [LTS] qpid proton cpp client and LVQ, duplicate acks and messages

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: