Spring JMS-通过将消息发送回相同队列而不是回滚事务来重新传递

Question

这是我在这里的第一个帖子，所以如果我不尊重格式规则或其他一般规则，我提前道歉。

我有一个基于Spring JMS的客户机应用程序，它使用多个使用者从队列中读取。我的约束条件是：在失败的情况下保证重发和消息重复检测。

<bean id="jndiDestinationResolver" class="org.springframework.jms.support.destination.DynamicDestinationResolver" />


    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <constructor-arg ref="MyConnectionFactory" />
        <property name="destinationResolver" ref="jndiDestinationResolver" />
        <property name="receiveTimeout" value="100" />
    </bean>


    <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="destinationResolver" ref="jndiDestinationResolver" />
            <property name="connectionFactory" ref="MyConnectionFactory" />
            <property name="destinationName" value="my_Queue" />
            <property name="messageListener" ref="MyListener" />
            <property name="maxConcurrentConsumers" value="10"/>
            <property name="sessionTransacted" value="true"/>
    </bean>

    protected void processTextMessage(TextMessage textMessage) {
        try {
            // process message
        } catch(Exception e) {
            try {
                sendTextMessage("my_Queue",correlationID, textMessage.getText());
            } catch (JMSException e1) {
                log.error("Error writing message back to the queue!");
                throw JmsUtils.convertJmsAccessException(e1);

            }
        }
    }


    protected void sendTextMessage(String queueName, final byte[] correlationID, String message) {
        jmsTemplate.convertAndSend(queueName, message, new MessagePostProcessor() {
            public Message postProcessMessage(Message message) throws JMSException {
                message.setJMSCorrelationIDAsBytes(correlationID);
                return message;
            }
        });
    }

我希望这对于我将要使用的JMS提供程序是透明的（在生产环境中使用Websphere MQ）。目前，我希望通过抛出一个异常来避免回滚事务：我希望重新调度失败的消息，就像队列中的新消息一样。对于重复检测，我认为插入一个业务存在检查就足够了。

事先表示感谢并致以最良好的问候

Answer 1

是的，这是正确的做法。