问如何使用spring data couchbase获取用于文档创建/删除的couchbase db事件

EN

    @Component
public class CouchbaseEventListener<E> implements ApplicationListener<CouchbaseMappingEvent<?>> {

    private static final Logger logger = LoggerFactory.getLogger(CouchbaseEventListener.class.getName());

    private final Class<?> domainClass;


    private static final String UNKNOWN = "unknown";

    String getKeyValue(CouchbaseDocument doc, String keyName, String def) {
        return doc.containsKey(keyName) ? (String)doc.get(keyName) : def;
    }
    String getKeyValue(CouchbaseDocument doc, String keyName) {
        return getKeyValue(doc, keyName, UNKNOWN);
    }


    public CouchbaseEventListener () {
        Class<?> typeArgument = GenericTypeResolver.resolveTypeArgument(getClass(), AbstractCouchbaseEventListener.class);
        domainClass = typeArgument == null ? Object.class : typeArgument;
    }

    @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) {
            logger.info("================= BeforeDeleteEvent() {}, {}", event.getSource(), event.getDocument());
            onBeforeDelete(event.getSource(), event.getDocument());
            return;
        }
        else if (event instanceof AfterDeleteEvent) {
            onAfterDelete(event.getSource(), event.getDocument());
            return;
        }

        if (event instanceof BeforeConvertEvent) {
            onBeforeConvert(source);
        }
        else if (event instanceof BeforeSaveEvent) {
            logger.info("================= BeforeSaveEvent() {}, {}", event.getSource(), event.getDocument());
            onBeforeSave(source, event.getDocument());
        }
        else if (event instanceof AfterSaveEvent) {
            onAfterSave(source, event.getDocument());
        }
    }


    public void onBeforeConvert(E source) {
      // Something goes here
    }

    public void onBeforeSave(E source, CouchbaseDocument doc) {
    }

    public void onAfterSave(E source, CouchbaseDocument doc) {
        if (doc!=null) {
            String id = (String)doc.getId();
            String wellId = getKeyValue(doc, "wellId", "(null)");
            String data = getFullEventDataString(source, doc, id);
            if (data != null) {
                logger.info("Hello Here := onAfterSave() . {}", data);
            }
        }
    }

    public void onAfterDelete(Object source, CouchbaseDocument doc) {
      // something goes here
 
    }

    public void onBeforeDelete(Object source, CouchbaseDocument doc) {
    }

    @Autowired
    private ApplicationContext appContext;

   
    }