4

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>
4

1 回答 1

6

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

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

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

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

于 2012-10-31T19:50:52.547 回答