Moving messages between elements of a composite queue fails

Solution Verified - Updated -

Issue

I have configured a composite queues as follows:

...
 <queue physicalName="myqueue.in.service"/>
 <queue physicalName="arc.myqueue.store"/>
 ...
 <compositeQueue name="myqueue.in.>" forwardOnly="false">
    <forwardTo>
      <queue physicalName="arc.myqueue.store"/>
    </forwardTo>
 </compositeQueue>
 ...

A message is sent to and consumed from myqueue.in.service:

java -jar lib/karaf/extras/mq-client.jar producer --user XXX --password XXX --brokerUrl failover://tcp://localhost:61618 --destination queue://myqueue.in.service --count 1

java -jar lib/karaf/extras/mq-client.jar consumer --user XXX --password XXX --brokerUrl failover://tcp://localhost:61618 --destination queue://myqueue.in.service --count 1

When trying to move a message from arc.myqueue.store back to myqueue.in.service it fails with the following output:

  • Duplicate message add attempt rejected. Destination: QUEUE://arc.myqueue.store, cursor got duplicate:
  • according to redelivery policy the insert is tried a couple of times
  • for each time the message counter is incremented in myqueue.in.service although the move is never successful and the message does not make it to myqueue.in.service.
  • finally the message ends up in the dlq

Environment

  • Red Hat JBoss A-MQ
    • 6.x

Subscriber exclusive content

A Red Hat subscription provides unlimited access to our knowledgebase of over 48,000 articles and solutions.

Current Customers and Partners

Log in for full access

Log In
Close

Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.