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 of over 48,000 articles and solutions.
Welcome! Check out the Getting Started with Red Hat page for quick tours and guides for common tasks.
