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

Añade nuevos eventos a la factoría

parent 60d5118f
Loading
Loading
Loading
Loading
+24 −0
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@ import es.redmic.vesselslib.dto.vessel.VesselDTO;
import es.redmic.vesselslib.events.vessel.common.VesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.common.VesselEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselEnrichedEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselFailedEvent;
@@ -20,11 +21,13 @@ import es.redmic.vesselslib.events.vessel.create.VesselCreatedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckFailedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselFailedEvent;
import es.redmic.vesselslib.events.vessel.delete.VesselDeletedEvent;
import es.redmic.vesselslib.events.vessel.partialupdate.vesseltype.UpdateVesselTypeInVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEnrichedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselFailedEvent;
@@ -52,6 +55,27 @@ public class VesselEventFactory {
			return new DeleteVesselCheckedEvent().buildFrom(source);
		}

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

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

			return new CreateVesselConfirmedEvent().buildFrom(source);
		}

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

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

			return new UpdateVesselConfirmedEvent().buildFrom(source);
		}

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

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

			return new DeleteVesselConfirmedEvent().buildFrom(source);
		}

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

			logger.info("Creando evento VesselDeletedEvent para: " + source.getAggregateId());
+24 −0
Original line number Diff line number Diff line
@@ -14,6 +14,7 @@ import es.redmic.vesselslib.events.vessel.common.VesselEvent;
import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingCancelledEvent;
import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingCancelledEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingConfirmedEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingEnrichedEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingFailedEvent;
@@ -21,11 +22,13 @@ import es.redmic.vesselslib.events.vesseltracking.create.VesselTrackingCreatedEv
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingCancelledEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingCheckFailedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingCheckedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingConfirmedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingFailedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.VesselTrackingDeletedEvent;
import es.redmic.vesselslib.events.vesseltracking.partialupdate.vessel.UpdateVesselInVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingCancelledEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingConfirmedEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingEnrichedEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingFailedEvent;
@@ -51,6 +54,27 @@ public class VesselTrackingEventFactory {
			return new DeleteVesselTrackingCheckedEvent().buildFrom(source);
		}

		if (type.equals(VesselTrackingEventTypes.CREATE_CONFIRMED)) {

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

			return new CreateVesselTrackingConfirmedEvent().buildFrom(source);
		}

		if (type.equals(VesselTrackingEventTypes.UPDATE_CONFIRMED)) {

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

			return new UpdateVesselTrackingConfirmedEvent().buildFrom(source);
		}

		if (type.equals(VesselTrackingEventTypes.DELETE_CONFIRMED)) {

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

			return new DeleteVesselTrackingConfirmedEvent().buildFrom(source);
		}

		if (type.equals(VesselTrackingEventTypes.DELETED)) {

			logger.info("Creando evento VesselTrackingDeletedEvent para: " + source.getAggregateId());
+24 −0
Original line number Diff line number Diff line
@@ -13,15 +13,18 @@ import es.redmic.vesselslib.dto.vesseltype.VesselTypeDTO;
import es.redmic.vesselslib.events.vesseltype.common.VesselTypeCancelledEvent;
import es.redmic.vesselslib.events.vesseltype.common.VesselTypeEvent;
import es.redmic.vesselslib.events.vesseltype.create.CreateVesselTypeCancelledEvent;
import es.redmic.vesselslib.events.vesseltype.create.CreateVesselTypeConfirmedEvent;
import es.redmic.vesselslib.events.vesseltype.create.CreateVesselTypeFailedEvent;
import es.redmic.vesselslib.events.vesseltype.create.VesselTypeCreatedEvent;
import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeCancelledEvent;
import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeCheckFailedEvent;
import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeCheckedEvent;
import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeConfirmedEvent;
import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeEvent;
import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeFailedEvent;
import es.redmic.vesselslib.events.vesseltype.delete.VesselTypeDeletedEvent;
import es.redmic.vesselslib.events.vesseltype.update.UpdateVesselTypeCancelledEvent;
import es.redmic.vesselslib.events.vesseltype.update.UpdateVesselTypeConfirmedEvent;
import es.redmic.vesselslib.events.vesseltype.update.UpdateVesselTypeFailedEvent;
import es.redmic.vesselslib.events.vesseltype.update.VesselTypeUpdatedEvent;

@@ -43,6 +46,27 @@ public class VesselTypeEventFactory {
			return new DeleteVesselTypeCheckedEvent().buildFrom(source);
		}

		if (type.equals(VesselTypeEventTypes.CREATE_CONFIRMED)) {

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

			return new CreateVesselTypeConfirmedEvent().buildFrom(source);
		}

		if (type.equals(VesselTypeEventTypes.UPDATE_CONFIRMED)) {

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

			return new UpdateVesselTypeConfirmedEvent().buildFrom(source);
		}

		if (type.equals(VesselTypeEventTypes.DELETE_CONFIRMED)) {

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

			return new DeleteVesselTypeConfirmedEvent().buildFrom(source);
		}

		if (type.equals(VesselTypeEventTypes.DELETED)) {

			logger.info("Creando evento VesselTypeDeletedEvent para: " + source.getAggregateId());
+63 −24
Original line number Diff line number Diff line
@@ -12,6 +12,7 @@ import es.redmic.vesselslib.events.vesseltracking.VesselTrackingEventFactory;
import es.redmic.vesselslib.events.vesseltracking.VesselTrackingEventTypes;
import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingCancelledEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingConfirmedEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingEnrichedEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.create.CreateVesselTrackingFailedEvent;
@@ -19,11 +20,13 @@ import es.redmic.vesselslib.events.vesseltracking.create.VesselTrackingCreatedEv
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingCancelledEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingCheckFailedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingCheckedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingConfirmedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.DeleteVesselTrackingFailedEvent;
import es.redmic.vesselslib.events.vesseltracking.delete.VesselTrackingDeletedEvent;
import es.redmic.vesselslib.events.vesseltracking.partialupdate.vessel.UpdateVesselInVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingCancelledEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingConfirmedEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingEnrichedEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingEvent;
import es.redmic.vesselslib.events.vesseltracking.update.UpdateVesselTrackingFailedEvent;
@@ -34,51 +37,61 @@ import es.redmic.vesselslib.unit.utils.VesselTrackingDataUtil;
public class VesselTrackingEventFactoryTest {

	@Test
	public void GetEvent_ReturnCreateVesselTrackingEnrichedEvent_IfTypeIsCreateEnriched() {
	public void GetEvent_ReturnDeleteVesselTrackingEvent_IfTypeIsDelete() {

		Event source = VesselTrackingDataUtil.getEnrichCreateVesselTrackingEvent();
		CreateVesselTrackingEnrichedEvent event = (CreateVesselTrackingEnrichedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.CREATE_ENRICHED,
						((VesselTrackingEvent) source).getVesselTracking());
		Event source = VesselTrackingDataUtil.getDeleteVesselTrackingCheckedEvent();
		DeleteVesselTrackingEvent event = (DeleteVesselTrackingEvent) VesselTrackingEventFactory.getEvent(source,
				VesselTrackingEventTypes.DELETE);

		assertEquals(VesselTrackingEventTypes.DELETE, event.getType());

		assertEquals(VesselTrackingEventTypes.CREATE_ENRICHED, event.getType());
		assertNotNull(event.getVesselTracking());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnUpdateVesselTrackingEnrichedEvent_IfTypeIsUpdateEnriched() {
	public void GetEvent_ReturnDeleteVesselTrackingCheckedEvent_IfTypeIsDelete_Checked() {

		Event source = VesselTrackingDataUtil.getEnrichUpdateVesselTrackingEvent();
		UpdateVesselTrackingEnrichedEvent event = (UpdateVesselTrackingEnrichedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.UPDATE_ENRICHED,
						((VesselTrackingEvent) source).getVesselTracking());
		Event source = VesselTrackingDataUtil.getCheckDeleteVesselTrackingEvent();
		DeleteVesselTrackingCheckedEvent event = (DeleteVesselTrackingCheckedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.DELETE_CHECKED);

		assertEquals(VesselTrackingEventTypes.DELETE_CHECKED, event.getType());

		assertEquals(VesselTrackingEventTypes.UPDATE_ENRICHED, event.getType());
		assertNotNull(event.getVesselTracking());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnDeleteVesselTrackingEvent_IfTypeIsDelete() {
	public void GetEvent_ReturnCreateVesselTrackingConfirmedEvent_IfTypeIsCreateConfirmed() {

		Event source = VesselTrackingDataUtil.getDeleteVesselTrackingCheckedEvent();
		DeleteVesselTrackingEvent event = (DeleteVesselTrackingEvent) VesselTrackingEventFactory.getEvent(source,
				VesselTrackingEventTypes.DELETE);
		Event source = VesselTrackingDataUtil.getCreateConfirmedEvent();
		CreateVesselTrackingConfirmedEvent event = (CreateVesselTrackingConfirmedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.CREATE_CONFIRMED);

		assertEquals(VesselTrackingEventTypes.DELETE, event.getType());
		assertEquals(VesselTrackingEventTypes.CREATE_CONFIRMED, event.getType());

		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnDeleteVesselTrackingCheckedEvent_IfTypeIsDelete_Checked() {
	public void GetEvent_ReturnUpdateVesselTrackingConfirmedEvent_IfTypeIsUpdateConfirmed() {

		Event source = VesselTrackingDataUtil.getCheckDeleteVesselTrackingEvent();
		DeleteVesselTrackingCheckedEvent event = (DeleteVesselTrackingCheckedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.DELETE_CHECKED);
		Event source = VesselTrackingDataUtil.getUpdateVesselTrackingConfirmedEvent();
		UpdateVesselTrackingConfirmedEvent event = (UpdateVesselTrackingConfirmedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.UPDATE_CONFIRMED);

		assertEquals(VesselTrackingEventTypes.DELETE_CHECKED, event.getType());
		assertEquals(VesselTrackingEventTypes.UPDATE_CONFIRMED, event.getType());

		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnDeleteVesselTrackingConfirmedEvent_IfTypeIsDeleteConfirmed() {

		Event source = VesselTrackingDataUtil.getDeleteVesselTrackingConfirmedEvent();
		DeleteVesselTrackingConfirmedEvent event = (DeleteVesselTrackingConfirmedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.DELETE_CONFIRMED);

		assertEquals(VesselTrackingEventTypes.DELETE_CONFIRMED, event.getType());

		checkMetadataFields(source, event);
	}
@@ -97,6 +110,32 @@ public class VesselTrackingEventFactoryTest {

	/////////////////////////

	@Test
	public void GetEvent_ReturnCreateVesselTrackingEnrichedEvent_IfTypeIsCreateEnriched() {

		Event source = VesselTrackingDataUtil.getEnrichCreateVesselTrackingEvent();
		CreateVesselTrackingEnrichedEvent event = (CreateVesselTrackingEnrichedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.CREATE_ENRICHED,
						((VesselTrackingEvent) source).getVesselTracking());

		assertEquals(VesselTrackingEventTypes.CREATE_ENRICHED, event.getType());
		assertNotNull(event.getVesselTracking());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnUpdateVesselTrackingEnrichedEvent_IfTypeIsUpdateEnriched() {

		Event source = VesselTrackingDataUtil.getEnrichUpdateVesselTrackingEvent();
		UpdateVesselTrackingEnrichedEvent event = (UpdateVesselTrackingEnrichedEvent) VesselTrackingEventFactory
				.getEvent(source, VesselTrackingEventTypes.UPDATE_ENRICHED,
						((VesselTrackingEvent) source).getVesselTracking());

		assertEquals(VesselTrackingEventTypes.UPDATE_ENRICHED, event.getType());
		assertNotNull(event.getVesselTracking());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnCreateVesselTrackingEvent_IfTypeIsCreate() {

+60 −21
Original line number Diff line number Diff line
@@ -11,6 +11,7 @@ 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.CreateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselEnrichedEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselEvent;
import es.redmic.vesselslib.events.vessel.create.CreateVesselFailedEvent;
@@ -18,11 +19,13 @@ import es.redmic.vesselslib.events.vessel.create.VesselCreatedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckFailedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselEvent;
import es.redmic.vesselslib.events.vessel.delete.DeleteVesselFailedEvent;
import es.redmic.vesselslib.events.vessel.delete.VesselDeletedEvent;
import es.redmic.vesselslib.events.vessel.partialupdate.vesseltype.UpdateVesselTypeInVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselCancelledEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselConfirmedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEnrichedEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselEvent;
import es.redmic.vesselslib.events.vessel.update.UpdateVesselFailedEvent;
@@ -34,48 +37,60 @@ import es.redmic.vesselslib.unit.utils.VesselTypeDataUtil;
public class VesselEventFactoryTest {

	@Test
	public void GetEvent_ReturnCreateVesselEnrichedEvent_IfTypeIsCreateEnriched() {
	public void GetEvent_ReturnDeleteVesselEvent_IfTypeIsDelete() {

		Event source = VesselDataUtil.getEnrichCreateVesselEvent();
		CreateVesselEnrichedEvent event = (CreateVesselEnrichedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.CREATE_ENRICHED, ((VesselEvent) source).getVessel());
		Event source = VesselDataUtil.getDeleteVesselCheckedEvent();
		DeleteVesselEvent event = (DeleteVesselEvent) VesselEventFactory.getEvent(source, VesselEventTypes.DELETE);

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

		assertEquals(VesselEventTypes.CREATE_ENRICHED, event.getType());
		assertNotNull(event.getVessel());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnUpdateVesselEnrichedEvent_IfTypeIsUpdateEnriched() {
	public void GetEvent_ReturnDeleteVesselCheckedEvent_IfTypeIsDelete_Checked() {

		Event source = VesselDataUtil.getEnrichUpdateVesselEvent();
		UpdateVesselEnrichedEvent event = (UpdateVesselEnrichedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.UPDATE_ENRICHED, ((VesselEvent) source).getVessel());
		Event source = VesselDataUtil.getCheckDeleteVesselEvent();
		DeleteVesselCheckedEvent event = (DeleteVesselCheckedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.DELETE_CHECKED);

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

		assertEquals(VesselEventTypes.UPDATE_ENRICHED, event.getType());
		assertNotNull(event.getVessel());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnDeleteVesselEvent_IfTypeIsDelete() {
	public void GetEvent_ReturnCreateVesselConfirmedEvent_IfTypeIsCreateConfirmed() {

		Event source = VesselDataUtil.getDeleteVesselCheckedEvent();
		DeleteVesselEvent event = (DeleteVesselEvent) VesselEventFactory.getEvent(source, VesselEventTypes.DELETE);
		Event source = VesselDataUtil.getCreateConfirmedEvent();
		CreateVesselConfirmedEvent event = (CreateVesselConfirmedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.CREATE_CONFIRMED);

		assertEquals(VesselEventTypes.DELETE, event.getType());
		assertEquals(VesselEventTypes.CREATE_CONFIRMED, event.getType());

		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnDeleteVesselCheckedEvent_IfTypeIsDelete_Checked() {
	public void GetEvent_ReturnUpdateVesselConfirmedEvent_IfTypeIsUpdateConfirmed() {

		Event source = VesselDataUtil.getCheckDeleteVesselEvent();
		DeleteVesselCheckedEvent event = (DeleteVesselCheckedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.DELETE_CHECKED);
		Event source = VesselDataUtil.getUpdateVesselConfirmedEvent();
		UpdateVesselConfirmedEvent event = (UpdateVesselConfirmedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.UPDATE_CONFIRMED);

		assertEquals(VesselEventTypes.DELETE_CHECKED, event.getType());
		assertEquals(VesselEventTypes.UPDATE_CONFIRMED, event.getType());

		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnDeleteVesselConfirmedEvent_IfTypeIsDeleteConfirmed() {

		Event source = VesselDataUtil.getDeleteVesselConfirmedEvent();
		DeleteVesselConfirmedEvent event = (DeleteVesselConfirmedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.DELETE_CONFIRMED);

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

		checkMetadataFields(source, event);
	}
@@ -93,6 +108,30 @@ public class VesselEventFactoryTest {

	/////////////////////////

	@Test
	public void GetEvent_ReturnCreateVesselEnrichedEvent_IfTypeIsCreateEnriched() {

		Event source = VesselDataUtil.getEnrichCreateVesselEvent();
		CreateVesselEnrichedEvent event = (CreateVesselEnrichedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.CREATE_ENRICHED, ((VesselEvent) source).getVessel());

		assertEquals(VesselEventTypes.CREATE_ENRICHED, event.getType());
		assertNotNull(event.getVessel());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnUpdateVesselEnrichedEvent_IfTypeIsUpdateEnriched() {

		Event source = VesselDataUtil.getEnrichUpdateVesselEvent();
		UpdateVesselEnrichedEvent event = (UpdateVesselEnrichedEvent) VesselEventFactory.getEvent(source,
				VesselEventTypes.UPDATE_ENRICHED, ((VesselEvent) source).getVessel());

		assertEquals(VesselEventTypes.UPDATE_ENRICHED, event.getType());
		assertNotNull(event.getVessel());
		checkMetadataFields(source, event);
	}

	@Test
	public void GetEvent_ReturnCreateVesselEvent_IfTypeIsCreate() {

Loading