From 051c43c0e911c9510ea92d7bbf0a45f4be68e6ca Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Fri, 5 Mar 2021 10:56:31 +0100
Subject: [PATCH] GH-2127 Wrap event publishing in try/catch issuing warning in
 case of error

Resolves #2127
---
 .../cloud/stream/binder/DefaultBinderFactory.java         | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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);
+							}
 						}
 					}
 				});