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

GH-2374 minor adjustments to functional error handling

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-06-13 19:34:45 +02:00
parent 07357d8c5a
commit 05d5ea9af8
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java
View File

@@ -707,6 +707,9 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
"Error channel '" + errorChannelName
+ "' must be a SubscribableChannel");
errorChannel = (SubscribableChannel) errorChannelObject;
if (this.isSubscribable(errorChannel)) {
this.subscribeFunctionErrorHandler(errorChannelName, consumerProperties.getBindingName());
}
}
else {
BinderErrorChannel binderErrorChannel = new BinderErrorChannel();
@@ -715,7 +718,6 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
((GenericApplicationContext) getApplicationContext()).registerBean(
errorChannelName, SubscribableChannel.class, () -> errorChannel);
this.subscribeFunctionErrorHandler(errorChannelName, consumerProperties.getBindingName());
}