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 05f4a6807..6d00d3767 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 @@ -292,7 +292,13 @@ 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) { + e.printStackTrace(); + logger.warn("Failed to publish " + event, e); + } } } });