1) サーバーがクライアントにメッセージを送信します。
2) インバウンドチャネルアダプターは、コンシューマーからの「MANUAL」承認モード操作を待機するように構成されています
3)「TaskBundlereceiver」ビーンは「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>