INNER CODE UNIT · Java

handleAndClearEvent

chaokunyang/jkes · jkes-boot/jkes-spring-data-jpa/src/main/java/com/timeyang/jkes/spring/jpa/EventSupport.java:151

    public void handleAndClearEvent() {
        LinkedList<Event> events = EventContainer.getEvents();
        for (Event event : events) {
            if(event.getEventType() == Event.EventType.SAVE) {
                Event.SaveEvent saveEvent = (Event.SaveEvent) event;
                jkesKafkaProducer.send(saveEvent.getValue());
            }else if(event.getEventType() == Event.EventType.DELETE) {
                Event.DeleteEvent deleteEvent = (Event.DeleteEvent) event;

                jkesKafkaProducer.send(deleteTopic, "", deleteEvent);
            }else if(event.getEventType() == Event.EventType.DELETE_ALL) {
                Event.DeleteAllEvent deleteAllEvent = (Event.DeleteAllEvent) event;
                Class<?> domainClass = deleteAllEvent.getDomainClass();

                // delete index
                String indexName = deleteAllEvent.getIndex();
                indicesAdminClient.deleteIndex(indexName);
                // recreate index

View source record →