Loading src/main/java/es/redmic/commandslib/streaming/streams/EventSourcingStreams.java +0 −9 Original line number Diff line number Diff line Loading @@ -75,9 +75,6 @@ public abstract class EventSourcingStreams extends BaseStreams { // Failed change processFailedChangeStream(events, snapshotEvents); // PostUpdate processPostUpdateStream(events); // extra process processExtraStreams(events, snapshotEvents); Loading Loading @@ -252,12 +249,6 @@ public abstract class EventSourcingStreams extends BaseStreams { protected abstract Event getDeleteCancelledEvent(Event failedEvent, Event lastSuccessEvent); /* * Función para procesar modificaciones de referencias */ protected abstract void processPostUpdateStream(KStream<String, Event> events); protected boolean isSameSession(Event a, Event b) { if (!(a.getSessionId().equals(b.getSessionId()))) { Loading Loading
src/main/java/es/redmic/commandslib/streaming/streams/EventSourcingStreams.java +0 −9 Original line number Diff line number Diff line Loading @@ -75,9 +75,6 @@ public abstract class EventSourcingStreams extends BaseStreams { // Failed change processFailedChangeStream(events, snapshotEvents); // PostUpdate processPostUpdateStream(events); // extra process processExtraStreams(events, snapshotEvents); Loading Loading @@ -252,12 +249,6 @@ public abstract class EventSourcingStreams extends BaseStreams { protected abstract Event getDeleteCancelledEvent(Event failedEvent, Event lastSuccessEvent); /* * Función para procesar modificaciones de referencias */ protected abstract void processPostUpdateStream(KStream<String, Event> events); protected boolean isSameSession(Event a, Event b) { if (!(a.getSessionId().equals(b.getSessionId()))) { Loading