Hi,

I'm trying to setup individual DLQ's for each of the subscribers to a topic.
I tried setting this up using the destinationPerDurableSubscriber="true"
for the individualDeadLetterStrategy as follows:

       <destinationPolicy>
            <policyMap>
              <policyEntries>
                <policyEntry topic=">" >
                    <!-- The constantPendingMessageLimitStrategy is used to
prevent
                         slow topic consumers to block producers and affect
other consumers
                         by limiting the number of messages that are
retained
                         For more information, see:


http://activemq.apache.org/slow-consumer-handling.html

                    -->
                  <pendingMessageLimitStrategy>
                    <constantPendingMessageLimitStrategy limit="1000"/>
                  </pendingMessageLimitStrategy>
  <deadLetterStrategy>
<individualDeadLetterStrategy topicPrefix="DLQ."
destinationPerDurableSubscriber="true" />
  </deadLetterStrategy>
                </policyEntry>
              </policyEntries>
            </policyMap>
        </destinationPolicy>

When testing this configuration I notice mixed results which seems pretty
random. One time a message has been put in the correct DLQ whereas the next
time it has been put in the DLQ specific to another subscriber to the same
topic.

Could I be missing something in this configuration ?
Could transactions be interfering ?

Kind regards,

Xander

Reply via email to