确认确认通道没有被调用

Question

以下是我的配置。如果成功发布到队列，则流程不会传递到确认确认通道。谁能指出哪里出错了？

<int-amqp:outbound-channel-adapter channel="fulfillmentOutboundChannel"
                                   routing-key="xyz"
                                   amqp-template="transactionalRabbitTemplate"
                                   confirm-correlation-expression="payload"
                                   confirm-ack-channel="successRespTransformChannel"
                                   confirm-nack-channel="failureRespTransformChannel"
                                   return-channel="failureRespTransformChannel"
                                   mapped-request-headers="*"


        />


<int:channel id="successRespTransformChannel">

    <int:interceptors><int:wire-tap channel="loggerChannel"/></int:interceptors>
</int:channel>

<chain input-channel="successRespTransformChannel">
    <int:header-enricher>
    <error-channel ref="failed-publishing" />
    </int:header-enricher>
    <service-activator id="successResp" expression="@abc.addRequestTracking(payload.id,'success')"/>

</chain>

Answer 1

为了得到acks/nacks，除了用confirm-correlation设置适配器，还需要在CachingConnectionFactory上启用publisherConfirms。

来自the documentation：

对于发布者确认（又名发布者确认），模板需要将其 publisherConfirms 属性设置为 true 的 CachingConnectionFactory。

Answer 2

感谢您的回复加里。我已经做出了 publish-confirms=true 如下..

<rabbit:connection-factory id="fufillConnectionFactory"

 connection-factory="rabbitClientConnectionFactory"
                               publisher-confirms="true"
                               publisher-returns="true"/>


    <bean id="rabbitClientConnectionFactory" class="com.rabbitmq.client.ConnectionFactory" >
        <property name="uri" value="${mq.uri}" />
        <property name="requestedHeartbeat" value="30" />
    </bean>