Moving messages between elements of a composite queue fails
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.