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, tools, and much more.

Current Customers and Partners

Log in for full access

Log In

New to Red Hat?

Learn more about Red Hat subscriptions

Using a Red Hat product through a public cloud?

How to access this content