diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java index da19f70d0..50424b03c 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinderFactory.java @@ -298,7 +298,12 @@ public class DefaultBinderFactory implements BinderFactory, DisposableBean, Appl @Override public void onApplicationEvent(ApplicationEvent event) { if (context != null) { - context.publishEvent(event); + try { + context.publishEvent(event); + } + catch (Exception e) { + logger.warn("Failed to publish " + event, e); + } } } });