Commit 6e8827c6 authored by Noel Alonso's avatar Noel Alonso
Browse files

Modifica creación de eventos en factoría

parent cc5daa62

vessels-lib/src/main/java/es/redmic/vesselslib/dto/tracking/VesselTrackingDTO.java

0 → 100644
+5 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.dto.tracking;



public class VesselTrackingDTO {



}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vessel/VesselEventFactory.java

+14 −14
Original line number Diff line number Diff line
@@ -38,20 +38,6 @@ public class VesselEventFactory { 


	public static Event getEvent(Event source, String type) {



		if (type.equals(VesselEventTypes.CREATE_ENRICHED)) {



			logger.info("Creando evento CreateVesselEnrichedEvent para: " + source.getAggregateId());



			return new CreateVesselEnrichedEvent().buildFrom(source);

		}



		if (type.equals(VesselEventTypes.UPDATE_ENRICHED)) {



			logger.info("Creando evento UpdateVesselEnrichedEvent para: " + source.getAggregateId());



			return new UpdateVesselEnrichedEvent().buildFrom(source);

		}



		if (type.equals(VesselEventTypes.DELETE)) {



			logger.info("Creando evento DeleteVesselEvent para: " + source.getAggregateId());
@@ -83,6 +69,20 @@ public class VesselEventFactory { 


		VesselEvent successfulEvent = null;



		if (type.equals(VesselEventTypes.CREATE_ENRICHED)) {



			logger.info("Creando evento CreateVesselEnrichedEvent para: " + source.getAggregateId());



			successfulEvent = new CreateVesselEnrichedEvent().buildFrom(source);

		}



		if (type.equals(VesselEventTypes.UPDATE_ENRICHED)) {



			logger.info("Creando evento UpdateVesselEnrichedEvent para: " + source.getAggregateId());



			successfulEvent = new UpdateVesselEnrichedEvent().buildFrom(source);

		}



		if (type.equals(VesselEventTypes.CREATE)) {



			logger.info("Creando evento CreateVesselEvent para: " + source.getAggregateId());

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/VesselTrackingEventTypes.java

0 → 100644
+16 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltracking;



import es.redmic.brokerlib.avro.common.EventTypes;



public abstract class VesselTrackingEventTypes extends EventTypes {



	public static String

	// @formatter:off

		UPDATE_VESSEL = "UPDATE_VESSEL";

	//@formatter:on



	public static boolean isLocked(String eventType) {



		return EventTypes.isLocked(eventType);

	}

}

vessels-lib/src/test/java/es/redmic/vesselslib/unit/events/vessel/VesselEventFactoryTest.java

+5 −4
Original line number Diff line number Diff line
@@ -9,6 +9,7 @@ import es.redmic.brokerlib.avro.common.Event; 
import es.redmic.brokerlib.avro.common.EventError;

import es.redmic.vesselslib.events.vessel.VesselEventFactory;

import es.redmic.vesselslib.events.vessel.VesselEventTypes;

import es.redmic.vesselslib.events.vessel.common.VesselEvent;

import es.redmic.vesselslib.events.vessel.create.CreateVesselCancelledEvent;

import es.redmic.vesselslib.events.vessel.create.CreateVesselEnrichedEvent;

import es.redmic.vesselslib.events.vessel.create.CreateVesselEvent;
@@ -37,10 +38,10 @@ public class VesselEventFactoryTest { 


		Event source = VesselDataUtil.getEnrichCreateVesselEvent();

		CreateVesselEnrichedEvent event = (CreateVesselEnrichedEvent) VesselEventFactory.getEvent(source,

				VesselEventTypes.CREATE_ENRICHED);

				VesselEventTypes.CREATE_ENRICHED, ((VesselEvent) source).getVessel());



		assertEquals(VesselEventTypes.CREATE_ENRICHED, event.getType());



		assertNotNull(event.getVessel());

		checkMetadataFields(source, event);

	}
@@ -49,10 +50,10 @@ public class VesselEventFactoryTest { 


		Event source = VesselDataUtil.getEnrichUpdateVesselEvent();

		UpdateVesselEnrichedEvent event = (UpdateVesselEnrichedEvent) VesselEventFactory.getEvent(source,

				VesselEventTypes.UPDATE_ENRICHED);

				VesselEventTypes.UPDATE_ENRICHED, ((VesselEvent) source).getVessel());



		assertEquals(VesselEventTypes.UPDATE_ENRICHED, event.getType());



		assertNotNull(event.getVessel());

		checkMetadataFields(source, event);

	}