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 8e487d95a..d0b1b3597 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 @@ public void maybeEmitEvent(CouchbaseMappingEvent event) { 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 845d9ca45..a1da79231 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 @@ public void maybeEmitEvent(CouchbaseMappingEvent event) { 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");