You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Colin Freas (JIRA)" <ji...@apache.org> on 2014/02/28 22:20:27 UTC

[jira] [Created] (AMQ-5079) compositeQueue and deadLetterStrategy: messages disappearing

Colin Freas created AMQ-5079:
--------------------------------

             Summary: compositeQueue and deadLetterStrategy: messages disappearing
                 Key: AMQ-5079
                 URL: https://issues.apache.org/jira/browse/AMQ-5079
             Project: ActiveMQ
          Issue Type: Bug
    Affects Versions: 5.9.0
            Reporter: Colin Freas
            Priority: Critical


Using a {{compositeQueue}} and a {{deadLetterStrategy}} like this:
{noformat}
<policyEntry queue=">">
  <deadLetterStrategy>         
    <individualDeadLetterStrategy queuePrefix="DLQ." useQueueForQueueMessages="true"/>
  </deadLetterStrategy>
</policyEntry>

<compositeQueue name="order.queue">
  <forwardTo>
    <queue physicalName="order.queue-1" />
    <queue physicalName="order.queue-2" />
  </forwardTo>
</compositeQueue>
{noformat}

The behavior I expect is this: 
* A message is sent to {{order.queue}}.  
* {{order.queue}} forwards messages to {{order.queue-1}} and {{order.queue-2}}.
* {{order.queue-1}} and {{order.queue-2}} fail to process the message.
* {{order.queue-1}} forwards message to {{DLQ.order.queue-1}}
* {{order.queue-2}} forwards message to {{DLQ.order.queue-2}}

The behavior I see is this:
* A message is sent to the {{order.queue}}.  
* {{order.queue}} forwards messages to {{order.queue-1}} and {{order.queue-2}}.
* {{order.queue-1}} and {{order.queue-2}} fail to process the message.
* {color:red}{{order.queue-1}} message disappears.{color}
* {{order.queue-2}} forwards message to {{DLQ.order.queue-2}}

The messages on {{order.queue-1}} and {{order.queue-2}} have the same message ID, and it seems like that's the issue.  When manually placing otherwise identical messages, the expected behavior is seen.




--
This message was sent by Atlassian JIRA
(v6.1.5#6160)