From edaf11ed85384558e31368228b7a6424d440de6b Mon Sep 17 00:00:00 2001
From: Michael Reiche <48999328+mikereiche@users.noreply.github.com>
Date: Thu, 26 Aug 2021 15:09:34 -0700
Subject: [PATCH] Log warning message and rethrow exceptions from events.
 (#1207)

Closes #1206.
---
 .../data/couchbase/core/CouchbaseTemplateSupport.java          | 3 ++-
 .../data/couchbase/core/ReactiveCouchbaseTemplateSupport.java  | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplateSupport.java b/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplateSupport.java
index 8e487d95..d0b1b359 100644
--- a/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplateSupport.java
+++ b/src/main/java/org/springframework/data/couchbase/core/CouchbaseTemplateSupport.java
@@ -182,7 +182,8 @@ class CouchbaseTemplateSupport implements ApplicationContextAware, TemplateSuppo
 			try {
 				this.applicationContext.publishEvent(event);
 			} catch (Exception e) {
-				LOG.error("exception emitting event "+event, e);
+				LOG.warn("{} thrown during {}", e, event);
+				throw e;
 			}
 		} else {
 			LOG.info("maybeEmitEvent called, but CouchbaseTemplate not initialized with applicationContext");
diff --git a/src/main/java/org/springframework/data/couchbase/core/ReactiveCouchbaseTemplateSupport.java b/src/main/java/org/springframework/data/couchbase/core/ReactiveCouchbaseTemplateSupport.java
index 845d9ca4..a1da7923 100644
--- a/src/main/java/org/springframework/data/couchbase/core/ReactiveCouchbaseTemplateSupport.java
+++ b/src/main/java/org/springframework/data/couchbase/core/ReactiveCouchbaseTemplateSupport.java
@@ -189,7 +189,8 @@ class ReactiveCouchbaseTemplateSupport implements ApplicationContextAware, React
 			try {
 				this.applicationContext.publishEvent(event);
 			} catch (Exception e) {
-				LOG.error("exception emitting event "+event, e);
+				LOG.warn("{} thrown during {}", e, event);
+				throw e;
 			}
 		} else {
 			LOG.info("maybeEmitEvent called, but ReactiveCouchbaseTemplate not initialized with applicationContext");