From 0b297fcb3786603751ecccec2ca5b396c93d35f3 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          | 7 ++++++-
 1 file changed, 6 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 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);
+							}
 						}
 					}
 				});