SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-152: Inject nullChannel for confirm acks

Browse Source 
Fixes https://github.com/spring-cloud/spring-cloud-stream-binder-rabbit/issues/152

Reduce log noise since we only express interest in nacks.
This commit is contained in:
Gary Russell
2018-05-22 11:17:28 -04:00
committed by Artem Bilan
parent a8bf0e8a09
commit 5a95735615
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/RabbitMessageChannelBinder.java
View File

@@ -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());
}