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");