使用Spring JMS路由到ActiveMQ中的DLQ的自定义异常

Question

我使用代理activemq 5.5.1和Spring JMS进行消息传递。我有如下要求

A） 我只想在相应的异常发生时将消息推入DLQ。目前，根据我的理解，在指定重试参数后，从MessageListeners抛出的任何异常都会移动到DLQ。ActiveMQ是否提供此功能以及如何提供？

B） 我必须根据类级别控制重试机制，这意味着自定义异常不重试。例如，如果抛出了MyException类的实例，那么我不应该重试这些消息，这样它就不会转到DLQ。请告知

编辑-----------

我试图限制重试尝试时，JMSRe，是真。但是这个消息，虽然异常只抛出一次重试，它没有添加到DLQ。这是我的测试代码。我使用的是Activemq 5.5.1

 public void onMessage(Message message) {
    try {
        if (message != null)
            if (message instanceof TextMessage) {
                String messageContent = ((TextMessage) message).
                if (message.getBooleanProperty("JMSRedelivered")) {
                    throw new CustomException1();
                } else {
                    throw new CustomJMSException("Retry Logic");
                }
            }
        }
    } catch (JMSException jmsex) {

    } catch (CustomException1 e) {
        System.out.println("Exception Caught");
    } catch (CustomJMSException e) {
        throw new CustomJMSException("Exception thrown");
    }


Spring Configuration:

<bean id="redeliveryPolicy1" class="org.apache.activemq.RedeliveryPolicy">
    <property name="initialRedeliveryDelay" value="1000" />
    <property name="redeliveryDelay" value="1000" /> 
    <property name="maximumRedeliveries" value="5" />
    <property name="useExponentialBackOff" value="false" />
    <property name="backOffMultiplier" value="1" /> 
</bean>

Answer 1

答案1）是的，ActiveMQ具有开箱即用的功能，其中失败的消息（当然，在某些重试之后）会自动移动到名为ActiveMQ的队列中。DLQ，这是代理中所有队列的默认死信队列

Answer 2

您需要做的就是捕获（并忽略或记录）要忽略的异常，然后重新抛出要路由到DLQ的异常。

或者，您可以使用sping-retry而不是activeMQ的机制；它有确定应该重试哪些异常的策略，以及允许您决定吸收或重新抛出哪些异常的RecoveryCallback。