From 5a9573561548f3e2709b1fa423f189a0c0bb2179 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Tue, 22 May 2018 11:17:28 -0400 Subject: [PATCH] GH-152: Inject nullChannel for confirm acks Fixes https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/152 Reduce log noise since we only express interest in nacks. --- .../cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java index 2caea8064..9dfb89541 100644 --- a/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java +++ b/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java @@ -285,6 +285,8 @@ public class RabbitMessageChannelBinder checkConnectionFactoryIsErrorCapable(); endpoint.setReturnChannel(errorChannel); endpoint.setConfirmNackChannel(errorChannel); + endpoint.setConfirmAckChannel(getApplicationContext().getBean( + IntegrationContextUtils.NULL_CHANNEL_BEAN_NAME, MessageChannel.class)); endpoint.setConfirmCorrelationExpressionString("#root"); endpoint.setErrorMessageStrategy(new DefaultErrorMessageStrategy()); }