Spring AMQP发布商在amqp出站网关中确认

Question

我正在使用spring amqp使用出站网关将消息发布到RabbitMQ。我在连接工厂上设置了publisher confirms，并添加了自定义回调侦听器。

问题是我的相关数据总是空，我不能在出站网关上添加任何相关数据。这仅适用于出站通道适配器。

对于出站网关，出版商是否会确认工作？

编辑我的配置如下。我查看了SI代码，是的，publisher确认已启用。问题是当我收到NACK时我会做什么？由于出站网关，我不需要相关id来处理响应，已经有一个线程在临时响应队列上侦听响应。

在出站网关中使用发布者确认到底有什么意义？如果没有响应，或者我的Rabbit节点下降，我会遇到异常。有没有可能我会丢失消息？

<rabbit:connection-factory id="rabbitConnectionFactory"
                               host="someip" port="5672"
                               username="username"
                               password="password"
                               virtual-host="vhost"
                               publisher-confirms="true"/>

    <rabbit:admin connection-factory="rabbitConnectionFactory"/>

    <rabbit:template id="amqpTemplate" connection-factory="rabbitConnectionFactory"
                     confirm-callback="messagesConfirmCallback"/>

 <int-amqp:outbound-gateway
            request-channel="channel"
            amqp-template="amqpTemplate"
            exchange-name="exchange"
            routing-key-expression="headers['queueSpecific']+'.queue'">
        <amqp:request-handler-advice-chain>
            <ref bean="retryAdvice"/>
        </amqp:request-handler-advice-chain>
    </int-amqp:outbound-gateway>

我的回调也很简单

@Component
public class MessagesConfirmCallback implements RabbitTemplate.ConfirmCallback {

    private final static Logger LOGGER = LoggerFactory.getLogger(MessagesConfirmCallback.class);

    @Override
    public void confirm(CorrelationData correlationData, boolean ack) {
        if(ack){
            LOGGER.info("ACK received");
        }
        else{
            LOGGER.info("NACK received");
        }
    }
}

这

Answer 1

不幸的是，我没有看到一个简单的工作与网关；底层的rabbitmplate只支持在send（）方法上添加相关数据，而不支持send和receive方法。

我能想到的两个选项是：（1）使用一对出站和入站适配器（而不是网关），但在这种情况下，您必须自己进行请求/应答关联。

或者（2），使用RabbitTemplate。execute（）并在doInRabbit回调中，添加与rabbitmplate中类似的代码。dosendReceive，同时按照doSend（）中的操作设置相关数据。

我打开了一个JIRA问题。