Commit f0a4ca75 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade la comprobación de si el item está en kafka 

Añade de nuevo la comprobación eliminada temporalmente para hacer
pruebas
parent 3fc8fa51

vessels-commands/src/main/java/es/redmic/vesselscommands/aggregate/VesselAggregate.java

+2 −2
Original line number Diff line number Diff line
@@ -34,10 +34,10 @@ public class VesselAggregate extends Aggregate { 


		String id = cmd.getVessel().getId();



		/*-if (exist(id)) {

		if (exist(id)) {

			logger.info("Descartando inserción de " + id + ". El item ya está registrado.");

			return null; // Se lanza excepción en el origen no aquí

		}-*/

		}

		this.setAggregateId(id);



		VesselEvent evt = null;

vessels-commands/src/main/java/es/redmic/vesselscommands/aggregate/VesselTrackingAggregate.java

+2 −2
Original line number Diff line number Diff line
@@ -34,10 +34,10 @@ public class VesselTrackingAggregate extends Aggregate { 


		String id = cmd.getVesselTracking().getId();



		/*-if (exist(id)) {

		if (exist(id)) {

			logger.info("Descartando inserción de " + id + ". El item ya está registrado.");

			return null; // Se lanza excepción en el origen no aquí

		}-*/

		}

		this.setAggregateId(id);



		VesselDTO vessel = cmd.getVesselTracking().getProperties().getVessel();

vessels-commands/src/test/java/es/redmic/test/vesselscommands/unit/aggregate/vessel/ProcessEventTest.java

+1 −1
Original line number Diff line number Diff line
@@ -26,7 +26,7 @@ public class ProcessEventTest extends AggregateBaseTest { 
	@Test

	public void processCreateVesselCommand_ReturnVesselCreatedEvent_IfProcessIsOk() {



		// when(vesselsStateStore.getVessel(any())).thenReturn(null);

		when(vesselsStateStore.getVessel(any())).thenReturn(null);



		VesselDTO vessel = getVessel();

vessels-commands/src/test/java/es/redmic/test/vesselscommands/unit/aggregate/vesseltracking/ProcessEventTest.java

+1 −1
Original line number Diff line number Diff line
@@ -30,7 +30,7 @@ public class ProcessEventTest extends AggregateBaseTest { 
	@Test

	public void processCreateVesselTrackingCommand_ReturnVesselTrackingCreatedEvent_IfProcessIsOk() {



		// when(vesselTrackingsStateStore.getVesselTracking(any())).thenReturn(null);

		when(vesselTrackingsStateStore.getVesselTracking(any())).thenReturn(null);



		VesselTrackingDTO vesselTracking = getVesselTracking();