Spring/spring-data-couchbase
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACOUCH-102 - Pass event source to onBeforeDelete() and onAfterDelete() event handlers

Browse Source
This commit is contained in:
Joel Stevenson
2014-08-13 15:04:34 -07:00
committed by Michael Nitschinger
parent bfc4019eb1
commit 76be140c07
2 changed files with 13 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/main/java/org/springframework/data/couchbase/core/mapping/event/AbstractCouchbaseEventListener.java
View File

@@ -41,17 +41,18 @@ public class AbstractCouchbaseEventListener<E> implements ApplicationListener<Co
@SuppressWarnings("rawtypes")
public void onApplicationEvent(CouchbaseMappingEvent<?> event) {
E source = (E) event.getSource();
// Check for matching domain type and invoke callbacks
if (source != null && !domainClass.isAssignableFrom(source.getClass())) {
return;
}
if (event instanceof BeforeDeleteEvent) {
onBeforeDelete(event.getDocument());
onBeforeDelete(event.getSource(), event.getDocument());
return;
} else if (event instanceof AfterDeleteEvent) {
onAfterDelete(event.getDocument());
return;
}
E source = (E) event.getSource();
// Check for matching domain type and invoke callbacks
if (source != null && !domainClass.isAssignableFrom(source.getClass())) {
onAfterDelete(event.getSource(), event.getDocument());
return;
}
@@ -82,13 +83,13 @@ public class AbstractCouchbaseEventListener<E> implements ApplicationListener<Co
}
}
public void onAfterDelete(CouchbaseDocument doc) {
public void onAfterDelete(Object source, CouchbaseDocument doc) {
if (LOG.isDebugEnabled()) {
LOG.debug("onAfterConvert({})", doc);
}
}
public void onBeforeDelete(CouchbaseDocument doc) {
public void onBeforeDelete(Object source, CouchbaseDocument doc) {
if (LOG.isDebugEnabled()) {
LOG.debug("onAfterConvert({})", doc);
}

8
src/main/java/org/springframework/data/couchbase/core/mapping/event/LoggingEventListener.java
View File

@@ -31,14 +31,10 @@ public class LoggingEventListener extends AbstractCouchbaseEventListener<Object>
private static final Logger LOGGER = LoggerFactory.getLogger(LoggingEventListener.class);
@Override
public void onBeforeDelete(CouchbaseDocument doc) {
LOGGER.info("onBeforeDelete: {}", doc);
}
public void onBeforeDelete(Object source, CouchbaseDocument doc) { LOGGER.info("onBeforeDelete: {}, {}", source, doc); }
@Override
public void onAfterDelete(CouchbaseDocument doc) {
LOGGER.info("onAfterDelete: {}", doc);
}
public void onAfterDelete(Object source, CouchbaseDocument doc) { LOGGER.info("onAfterDelete: {} {}", source, doc); }
@Override
public void onAfterSave(Object source, CouchbaseDocument doc) {