Spring 集成 JMS 问题

Question

我们正在使用 Spring 集成来使用队列中的消息，要求是在处理使用的消息时出现任何问题时将消息发送到错误队列。 Flow 工作正常，但我们看到的一个问题是，当消息处理过程中抛出任何异常时，消息被重定向到我们配置的错误队列，但它附加了异常的整个堆栈跟踪。我们只查找要传送到队列的原始消息。下面是我们完成的配置，

<bean id="errorQ" class="com.ibm.mq.jms.MQQueue">
    <constructor-arg value="${error.queue}" />
</bean>
<bean id="inQ" class="com.ibm.mq.jms.MQQueue">
    <constructor-arg value="${inbound.queue}" />
</bean>

<int:channel id="error" />
<int:channel id="inbound" />

<int-jms:message-driven-channel-adapter
    id="jmsIn" channel="inbound" container="messageListenerContainer"
    acknowledge="transacted"></int-jms:message-driven-channel-adapter>

<int-jms:outbound-channel-adapter id="jmsError"
channel="error" connection-factory="mqConnectionFactory"
destination="errorQ" delivery-persistent="true"></int-jms:outbound-channel-adapter>


<int:service-activator id="service"
input-channel="inbound" ref="messageListener" method="someMethodInListerner">
    <int:request-handler-advice-chain>
        <ref bean="retryWithBackoffAdviceSession" />
    </int:request-handler-advice-chain>

<bean id="retryWithBackoffAdviceSession"
    class="org.springframework.integration.handler.advice.RequestHandlerRetryAdvice">
    <property name="retryTemplate">
        <bean class="org.springframework.retry.support.RetryTemplate">
            <property name="backOffPolicy">
                <bean class="org.springframework.retry.backoff.ExponentialBackOffPolicy">
                    <property name="initialInterval" value="${initialInterval}" />
                    <property name="multiplier" value="${multiplier}" />
                    <property name="maxInterval" value="${maxInterval}" />
                </bean>
            </property>
            <property name="retryPolicy">
                <bean class="org.springframework.retry.policy.SimpleRetryPolicy">
                    <property name="maxAttempts" value="${redelivery}" />
                </bean>
            </property>
        </bean>
    </property>
    <property name="recoveryCallback">
        <bean
            class="org.springframework.integration.handler.advice.ErrorMessageSendingRecoverer">
            <constructor-arg ref="error" />
        </bean>
    </property>
</bean>

Answer 1

发送到 error 的消息是 ErrorMessage，有效载荷 MessagingException。

MessagingException有两个属性cause和failedMessage。

因此，如果您想将原始失败消息发送到 errorQ，您需要向错误流添加一个转换器...

<int:transformer ... expression="payload.failedMessage" />

编辑

<int:chain input-channel="error">
    <int:transformer expression="payload.failedMessage" />
    <int-jms:outbound-channel-adapter ... />
</int:chain>

EDIT2

通常，在使用这些技术时，传达失败的原因很有用。您可以将异常消息添加为 header...

<int:chain input-channel="error">
    <int:header-enricher>
        <int:header name="failureReason" expression="payload.cause.message" />
    </int:header-enricher>
    <int:transformer expression="payload.failedMessage" />
    <int-jms:outbound-channel-adapter ... />
</int:chain>

Spring 集成 JMS 问题

Spring Integration JMS Issue

jms

spring-integration

spring-retry