如何使用spring集成手动确认rabbitmq消息

Question

我已经为入站通道创建了带有手动确认属性的bean，以及用于发布输出消息的链式方法，

<int-amqp:inbound-channel-adapter channel="InputChannel" 
    queue-names="Input" connection-factory="connectionFactory" concurrent-consumers="1" message-converter="Converter"  
      acknowledge-mode="MANUAL" prefetch-count="5"/>

<int:chain input-channel="InputChannel" output-channel="OutputChannel">

      <int:transformer method = "transform" >
        <bean class="com.sampleconverter" />
      </int:transformer>
        <int:service-activator method="transform">
             <bean class="com.Transformer" />
        </int:service-activator>
     <int:object-to-string-transformer />
   </int:chain>

您能帮我了解一下手动确认模式处理的消息的确认方式吗，

提前致谢。

Answer 1

Reference Manual 有专门的段落讨论此事：

将模式设置为MANUAL 允许用户代码在处理期间的某个其他时间点确认消息。为了支持这一点，在这种模式下，端点分别在 amqp_channel 和 amqp_deliveryTag 标头中提供 Channel 和 deliveryTag。

@ServiceActivator(inputChannel = "foo", outputChannel = "bar")
public Object handle(@Payload String payload, @Header(AmqpHeaders.CHANNEL) Channel channel,
        @Header(AmqpHeaders.DELIVERY_TAG) Long deliveryTag) throws Exception {

    // Do some processing

    if (allOK) {
        channel.basicAck(deliveryTag, false);

        // perhaps do some more processing

    }
    else {
        channel.basicNack(deliveryTag, false, true);
    }
    return someResultForDownStreamProcessing;
}