spring-cloudGH-152: Inject nullChannel for confirm acks

Fixes spring-cloud#152 Reduce log noise since we only express interest in nacks.
garyrussell · May 22, 2018 · 1d0dcd3 · 1d0dcd3
1 parent a8bf0e8
commit 1d0dcd3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/.../main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java b/.../main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java
@@ -285,6 +285,8 @@ protected MessageHandler createProducerMessageHandler(final ProducerDestination
 			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());
 		}