Loading src/main/java/es/redmic/commandslib/streaming/streams/EventSourcingStreams.java +3 −2 Original line number Diff line number Diff line Loading @@ -236,9 +236,10 @@ public abstract class EventSourcingStreams extends BaseStreams { protected boolean isSameSession(Event a, Event b) { if (!(a.getSessionId().equals(b.getSessionId()))) { String message = "Recibido evento de petición " + b.getType() + " con id de sesión " + b.getSessionId() String message = "Evento de petición " + b.getType() + " con id de sesión " + b.getSessionId() + ", el cual es diferente al evento de confirmación " + a.getType() + " con id de sesión " + a.getSessionId() + " para item " + a.getAggregateId(); + a.getSessionId() + " para item " + b.getAggregateId() + "|" + b.getDate() + " (" + a.getAggregateId() + "|" + a.getDate() + ")"; logger.error(message); // alertService.errorAlert(a.getAggregateId(), message); return false; Loading Loading
src/main/java/es/redmic/commandslib/streaming/streams/EventSourcingStreams.java +3 −2 Original line number Diff line number Diff line Loading @@ -236,9 +236,10 @@ public abstract class EventSourcingStreams extends BaseStreams { protected boolean isSameSession(Event a, Event b) { if (!(a.getSessionId().equals(b.getSessionId()))) { String message = "Recibido evento de petición " + b.getType() + " con id de sesión " + b.getSessionId() String message = "Evento de petición " + b.getType() + " con id de sesión " + b.getSessionId() + ", el cual es diferente al evento de confirmación " + a.getType() + " con id de sesión " + a.getSessionId() + " para item " + a.getAggregateId(); + a.getSessionId() + " para item " + b.getAggregateId() + "|" + b.getDate() + " (" + a.getAggregateId() + "|" + a.getDate() + ")"; logger.error(message); // alertService.errorAlert(a.getAggregateId(), message); return false; Loading