如何使用 Spring AMQP/Spring 集成通过程序确认消息

Question

1) 服务器向客户端发送消息。

2) 入站通道适配器配置为等待来自消费者的“手动”确认模式操作

3）“TaskBundlereceiver”bean 正在实现“ChannelAwareMessageListener”，在实现方法中，我正在执行消息确认。

我没有看到“TaskBundlereceiver”被执行。我错过了什么吗？

下面是我已经解释的步骤的配置细节。

感谢您的投入。

    @Override
    public void onMessage(org.springframework.amqp.core.Message message, Channel channel) throws Exception 
    {
        logger.debug("In onMessage method of the channel aware listener. message =["+message.getBody().toString()+"]");
        channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
    }

XML 配置：

    <!-- Channel that receives the task bundle from the server for execution -->
    <int:channel id="fromKServerChannel"/>

    <int-amqp:inbound-channel-adapter id="taskBundleReceiverAdapter"
                                      channel="fromKServerChannel"
                                      error-channel="taskBundleErrorChannel"
                                      acknowledge-mode="MANUAL"
                                      expose-listener-channel="true"
                                      queue-names="kanga_task_queue"
                                      connection-factory="connectionFactory"
                                      concurrent-consumers="20"/>

    <int:chain input-channel="fromKServerChannel" output-channel="nullChannel">
        <int:service-activator ref="taskBundleReceiver" method="onMessage"/>
        <int:service-activator ref="taskBundleExecutor" method="executeBundle"/>
    </int:chain>

Answer 1

这样不行；侦听器是适配器，而不是通过服务激活器调用的服务。适配器目前不支持将通道传递给客户端进行手动确认。 Expose-listener-channel 属性是在使用事务时使用的，因此下栈兔子模板可以参与事务。

为什么要手动确认？ AUTO（默认）表示当线程正常返回时，容器会自动完成ack；如果你的服务抛出异常，消息将被 nack。

所以，这就是控制 ack 的方法。

如果您真的想使用 MANUAL 确认，则必须使用 <rabbit:listener-container/> 直接调用您的 taskBundleReceiver。然后它可以使用消息传递网关向执行者发送消息。