Loading vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselEventStreams.java +4 −0 Original line number Diff line number Diff line Loading @@ -427,4 +427,8 @@ public class VesselEventStreams extends EventSourcingStreams { } return result; } @Override protected void processExtraStreams(KStream<String, Event> events) { } } vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTypeEventStreams.java +4 −0 Original line number Diff line number Diff line Loading @@ -198,4 +198,8 @@ public class VesselTypeEventStreams extends EventSourcingStreams { protected void processPostUpdateStream(KStream<String, Event> events) { // En este caso no hay modificación de relaciones } @Override protected void processExtraStreams(KStream<String, Event> events) { } } Loading
vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselEventStreams.java +4 −0 Original line number Diff line number Diff line Loading @@ -427,4 +427,8 @@ public class VesselEventStreams extends EventSourcingStreams { } return result; } @Override protected void processExtraStreams(KStream<String, Event> events) { } }
vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTypeEventStreams.java +4 −0 Original line number Diff line number Diff line Loading @@ -198,4 +198,8 @@ public class VesselTypeEventStreams extends EventSourcingStreams { protected void processPostUpdateStream(KStream<String, Event> events) { // En este caso no hay modificación de relaciones } @Override protected void processExtraStreams(KStream<String, Event> events) { } }