Commit 3fc8fa51 authored by Noel Alonso's avatar Noel Alonso
Browse files

Comenta temporalmente comprobar si está en kafka 

Comenta también tests relacionados.
parent 7ce44e50

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();