Loading vessels-lib/src/main/java/es/redmic/vesselslib/events/vessel/VesselEventFactory.java +20 −20 Original line number Diff line number Diff line Loading @@ -43,42 +43,42 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.DELETE)) { logger.info("Creando evento DeleteVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselEvent para: " + source.getAggregateId()); return new DeleteVesselEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETE_CHECKED)) { logger.info("Creando evento DeleteVesselCheckedEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselCheckedEvent para: " + source.getAggregateId()); return new DeleteVesselCheckedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATE_CONFIRMED)) { logger.info("Creando evento CreateVesselConfirmedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("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()); logger.debug("Creando evento DeleteVesselConfirmedEvent para: " + source.getAggregateId()); return new DeleteVesselConfirmedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETED)) { logger.info("Creando evento VesselDeletedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselDeletedEvent para: " + source.getAggregateId()); return new VesselDeletedEvent().buildFrom(source); } Loading @@ -95,39 +95,39 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.CREATE_ENRICHED)) { logger.info("Creando evento CreateVesselEnrichedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("Creando evento UpdateVesselEnrichedEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselEnrichedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATE)) { logger.info("Creando evento CreateVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento CreateVesselEvent para: " + source.getAggregateId()); successfulEvent = new CreateVesselEvent().buildFrom(source); } if (type.equals(VesselEventTypes.UPDATE)) { logger.info("Creando evento UpdateVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATED)) { logger.info("Creando evento VesselCreatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselCreatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselCreatedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.UPDATED)) { logger.info("Creando evento VesselUpdatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselUpdatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselUpdatedEvent().buildFrom(source); } Loading @@ -146,7 +146,7 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.UPDATE_VESSELTYPE)) { logger.info("Creando evento UpdateVesselTypeInVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTypeInVesselEvent para: " + source.getAggregateId()); UpdateVesselTypeInVesselEvent requestEvent = new UpdateVesselTypeInVesselEvent(); requestEvent.setAggregateId(source.getAggregateId()); Loading @@ -169,31 +169,31 @@ public class VesselEventFactory { if (type.equals(VesselTypeEventTypes.CREATE_FAILED)) { logger.info("No se pudo crear Vessel en la vista"); logger.debug("No se pudo crear Vessel en la vista"); failedEvent = new CreateVesselFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.UPDATE_FAILED)) { logger.info("No se pudo modificar Vessel en la vista"); logger.debug("No se pudo modificar Vessel en la vista"); failedEvent = new UpdateVesselFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_FAILED)) { logger.info("No se pudo eliminar Vessel de la vista"); logger.debug("No se pudo eliminar Vessel de la vista"); failedEvent = new DeleteVesselFailedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETE_CHECK_FAILED)) { logger.info("Checkeo de eliminación fallido, el item está referenciado"); logger.debug("Checkeo de eliminación fallido, el item está referenciado"); failedEvent = new DeleteVesselCheckFailedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATE_CANCELLED)) { logger.info("Enviando evento CreateVesselCancelledEvent para: " + source.getAggregateId()); logger.debug("Enviando evento CreateVesselCancelledEvent para: " + source.getAggregateId()); failedEvent = new CreateVesselCancelledEvent().buildFrom(source); } Loading @@ -218,13 +218,13 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.UPDATE_CANCELLED)) { logger.info("Creando evento UpdateVesselCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new UpdateVesselCancelledEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETE_CANCELLED)) { logger.info("Creando evento DeleteVesselCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new DeleteVesselCancelledEvent().buildFrom(source); } Loading vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/VesselTrackingEventFactory.java +19 −19 Original line number Diff line number Diff line Loading @@ -40,42 +40,42 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.DELETE)) { logger.info("Creando evento DeleteVesselTrackingEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTrackingEvent para: " + source.getAggregateId()); return new DeleteVesselTrackingEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_CHECKED)) { logger.info("Creando evento DeleteVesselTrackingCheckedEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTrackingCheckedEvent para: " + source.getAggregateId()); return new DeleteVesselTrackingCheckedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATE_CONFIRMED)) { logger.info("Creando evento CreateVesselTrackingConfirmedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("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()); logger.debug("Creando evento DeleteVesselTrackingConfirmedEvent para: " + source.getAggregateId()); return new DeleteVesselTrackingConfirmedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETED)) { logger.info("Creando evento VesselTrackingDeletedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTrackingDeletedEvent para: " + source.getAggregateId()); return new VesselTrackingDeletedEvent().buildFrom(source); } Loading @@ -92,39 +92,39 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.CREATE_ENRICHED)) { logger.info("Creando evento CreateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); logger.debug("Creando evento CreateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); successfulEvent = new CreateVesselTrackingEnrichedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATE_ENRICHED)) { logger.info("Creando evento UpdateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselTrackingEnrichedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATE)) { logger.info("Creando evento CreateVesselTrackingEvent para: " + source.getAggregateId()); logger.debug("Creando evento CreateVesselTrackingEvent para: " + source.getAggregateId()); successfulEvent = new CreateVesselTrackingEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATE)) { logger.info("Creando evento UpdateVesselTrackingEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTrackingEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselTrackingEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATED)) { logger.info("Creando evento VesselTrackingCreatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTrackingCreatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTrackingCreatedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATED)) { logger.info("Creando evento VesselTrackingUpdatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTrackingUpdatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTrackingUpdatedEvent().buildFrom(source); } Loading @@ -146,31 +146,31 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.CREATE_FAILED)) { logger.info("No se pudo crear VesselTracking en la vista"); logger.debug("No se pudo crear VesselTracking en la vista"); failedEvent = new CreateVesselTrackingFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATE_FAILED)) { logger.info("No se pudo modificar VesselTracking en la vista"); logger.debug("No se pudo modificar VesselTracking en la vista"); failedEvent = new UpdateVesselTrackingFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_FAILED)) { logger.info("No se pudo eliminar VesselTracking de la vista"); logger.debug("No se pudo eliminar VesselTracking de la vista"); failedEvent = new DeleteVesselTrackingFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_CHECK_FAILED)) { logger.info("Checkeo de eliminación fallido, el item está referenciado"); logger.debug("Checkeo de eliminación fallido, el item está referenciado"); failedEvent = new DeleteVesselTrackingCheckFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATE_CANCELLED)) { logger.info("Enviando evento CreateVesselTrackingCancelledEvent para: " + source.getAggregateId()); logger.debug("Enviando evento CreateVesselTrackingCancelledEvent para: " + source.getAggregateId()); failedEvent = new CreateVesselTrackingCancelledEvent().buildFrom(source); } Loading @@ -195,13 +195,13 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.UPDATE_CANCELLED)) { logger.info("Creando evento UpdateVesselTrackingCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTrackingCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new UpdateVesselTrackingCancelledEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_CANCELLED)) { logger.info("Creando evento DeleteVesselTrackingCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTrackingCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new DeleteVesselTrackingCancelledEvent().buildFrom(source); } Loading vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltype/VesselTypeEventFactory.java +15 −15 Original line number Diff line number Diff line Loading @@ -36,40 +36,40 @@ public class VesselTypeEventFactory { if (type.equals(VesselTypeEventTypes.DELETE)) { logger.info("Creando evento DeleteVesselTypeEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTypeEvent para: " + source.getAggregateId()); return new DeleteVesselTypeEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_CHECKED)) { logger.info("Creando evento DeleteVesselTypeCheckedEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTypeCheckedEvent para: " + source.getAggregateId()); return new DeleteVesselTypeCheckedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.CREATE_CONFIRMED)) { logger.info("Creando evento CreateVesselTypeConfirmedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("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()); logger.debug("Creando evento DeleteVesselTypeConfirmedEvent para: " + source.getAggregateId()); return new DeleteVesselTypeConfirmedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETED)) { logger.info("Creando evento VesselTypeDeletedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTypeDeletedEvent para: " + source.getAggregateId()); return new VesselTypeDeletedEvent().buildFrom(source); } Loading @@ -82,12 +82,12 @@ public class VesselTypeEventFactory { VesselTypeEvent successfulEvent = null; if (type.equals(VesselTypeEventTypes.CREATED)) { logger.info("Creando evento VesselTypeCreatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTypeCreatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTypeCreatedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.UPDATED)) { logger.info("Creando evento VesselTypeUpdatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTypeUpdatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTypeUpdatedEvent().buildFrom(source); } Loading @@ -107,29 +107,29 @@ public class VesselTypeEventFactory { if (type.equals(VesselTypeEventTypes.CREATE_FAILED)) { logger.info("No se pudo crear Vessel type en la vista"); logger.debug("No se pudo crear Vessel type en la vista"); failedEvent = new CreateVesselTypeFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.UPDATE_FAILED)) { logger.info("No se pudo modificar Vessel type en la vista"); logger.debug("No se pudo modificar Vessel type en la vista"); failedEvent = new UpdateVesselTypeFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_FAILED)) { logger.info("No se pudo eliminar Vessel type de la vista"); logger.debug("No se pudo eliminar Vessel type de la vista"); failedEvent = new DeleteVesselTypeFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_CHECK_FAILED)) { logger.info("Checkeo de eliminación fallido, el item está referenciado"); logger.debug("Checkeo de eliminación fallido, el item está referenciado"); failedEvent = new DeleteVesselTypeCheckFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.CREATE_CANCELLED)) { logger.info("Enviando evento CreateVesselTypeCancelledEvent para: " + source.getAggregateId()); logger.debug("Enviando evento CreateVesselTypeCancelledEvent para: " + source.getAggregateId()); failedEvent = new CreateVesselTypeCancelledEvent().buildFrom(source); } Loading @@ -152,13 +152,13 @@ public class VesselTypeEventFactory { if (type.equals(VesselTypeEventTypes.UPDATE_CANCELLED)) { logger.info("Creando evento UpdateVesselTypeCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTypeCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new UpdateVesselTypeCancelledEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_CANCELLED)) { logger.info("Creando evento DeleteVesselTypeCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTypeCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new DeleteVesselTypeCancelledEvent().buildFrom(source); } Loading Loading
vessels-lib/src/main/java/es/redmic/vesselslib/events/vessel/VesselEventFactory.java +20 −20 Original line number Diff line number Diff line Loading @@ -43,42 +43,42 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.DELETE)) { logger.info("Creando evento DeleteVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselEvent para: " + source.getAggregateId()); return new DeleteVesselEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETE_CHECKED)) { logger.info("Creando evento DeleteVesselCheckedEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselCheckedEvent para: " + source.getAggregateId()); return new DeleteVesselCheckedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATE_CONFIRMED)) { logger.info("Creando evento CreateVesselConfirmedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("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()); logger.debug("Creando evento DeleteVesselConfirmedEvent para: " + source.getAggregateId()); return new DeleteVesselConfirmedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETED)) { logger.info("Creando evento VesselDeletedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselDeletedEvent para: " + source.getAggregateId()); return new VesselDeletedEvent().buildFrom(source); } Loading @@ -95,39 +95,39 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.CREATE_ENRICHED)) { logger.info("Creando evento CreateVesselEnrichedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("Creando evento UpdateVesselEnrichedEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselEnrichedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATE)) { logger.info("Creando evento CreateVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento CreateVesselEvent para: " + source.getAggregateId()); successfulEvent = new CreateVesselEvent().buildFrom(source); } if (type.equals(VesselEventTypes.UPDATE)) { logger.info("Creando evento UpdateVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATED)) { logger.info("Creando evento VesselCreatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselCreatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselCreatedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.UPDATED)) { logger.info("Creando evento VesselUpdatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselUpdatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselUpdatedEvent().buildFrom(source); } Loading @@ -146,7 +146,7 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.UPDATE_VESSELTYPE)) { logger.info("Creando evento UpdateVesselTypeInVesselEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTypeInVesselEvent para: " + source.getAggregateId()); UpdateVesselTypeInVesselEvent requestEvent = new UpdateVesselTypeInVesselEvent(); requestEvent.setAggregateId(source.getAggregateId()); Loading @@ -169,31 +169,31 @@ public class VesselEventFactory { if (type.equals(VesselTypeEventTypes.CREATE_FAILED)) { logger.info("No se pudo crear Vessel en la vista"); logger.debug("No se pudo crear Vessel en la vista"); failedEvent = new CreateVesselFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.UPDATE_FAILED)) { logger.info("No se pudo modificar Vessel en la vista"); logger.debug("No se pudo modificar Vessel en la vista"); failedEvent = new UpdateVesselFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_FAILED)) { logger.info("No se pudo eliminar Vessel de la vista"); logger.debug("No se pudo eliminar Vessel de la vista"); failedEvent = new DeleteVesselFailedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETE_CHECK_FAILED)) { logger.info("Checkeo de eliminación fallido, el item está referenciado"); logger.debug("Checkeo de eliminación fallido, el item está referenciado"); failedEvent = new DeleteVesselCheckFailedEvent().buildFrom(source); } if (type.equals(VesselEventTypes.CREATE_CANCELLED)) { logger.info("Enviando evento CreateVesselCancelledEvent para: " + source.getAggregateId()); logger.debug("Enviando evento CreateVesselCancelledEvent para: " + source.getAggregateId()); failedEvent = new CreateVesselCancelledEvent().buildFrom(source); } Loading @@ -218,13 +218,13 @@ public class VesselEventFactory { if (type.equals(VesselEventTypes.UPDATE_CANCELLED)) { logger.info("Creando evento UpdateVesselCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new UpdateVesselCancelledEvent().buildFrom(source); } if (type.equals(VesselEventTypes.DELETE_CANCELLED)) { logger.info("Creando evento DeleteVesselCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new DeleteVesselCancelledEvent().buildFrom(source); } Loading
vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/VesselTrackingEventFactory.java +19 −19 Original line number Diff line number Diff line Loading @@ -40,42 +40,42 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.DELETE)) { logger.info("Creando evento DeleteVesselTrackingEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTrackingEvent para: " + source.getAggregateId()); return new DeleteVesselTrackingEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_CHECKED)) { logger.info("Creando evento DeleteVesselTrackingCheckedEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTrackingCheckedEvent para: " + source.getAggregateId()); return new DeleteVesselTrackingCheckedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATE_CONFIRMED)) { logger.info("Creando evento CreateVesselTrackingConfirmedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("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()); logger.debug("Creando evento DeleteVesselTrackingConfirmedEvent para: " + source.getAggregateId()); return new DeleteVesselTrackingConfirmedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETED)) { logger.info("Creando evento VesselTrackingDeletedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTrackingDeletedEvent para: " + source.getAggregateId()); return new VesselTrackingDeletedEvent().buildFrom(source); } Loading @@ -92,39 +92,39 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.CREATE_ENRICHED)) { logger.info("Creando evento CreateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); logger.debug("Creando evento CreateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); successfulEvent = new CreateVesselTrackingEnrichedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATE_ENRICHED)) { logger.info("Creando evento UpdateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTrackingEnrichedEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselTrackingEnrichedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATE)) { logger.info("Creando evento CreateVesselTrackingEvent para: " + source.getAggregateId()); logger.debug("Creando evento CreateVesselTrackingEvent para: " + source.getAggregateId()); successfulEvent = new CreateVesselTrackingEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATE)) { logger.info("Creando evento UpdateVesselTrackingEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTrackingEvent para: " + source.getAggregateId()); successfulEvent = new UpdateVesselTrackingEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATED)) { logger.info("Creando evento VesselTrackingCreatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTrackingCreatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTrackingCreatedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATED)) { logger.info("Creando evento VesselTrackingUpdatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTrackingUpdatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTrackingUpdatedEvent().buildFrom(source); } Loading @@ -146,31 +146,31 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.CREATE_FAILED)) { logger.info("No se pudo crear VesselTracking en la vista"); logger.debug("No se pudo crear VesselTracking en la vista"); failedEvent = new CreateVesselTrackingFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.UPDATE_FAILED)) { logger.info("No se pudo modificar VesselTracking en la vista"); logger.debug("No se pudo modificar VesselTracking en la vista"); failedEvent = new UpdateVesselTrackingFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_FAILED)) { logger.info("No se pudo eliminar VesselTracking de la vista"); logger.debug("No se pudo eliminar VesselTracking de la vista"); failedEvent = new DeleteVesselTrackingFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_CHECK_FAILED)) { logger.info("Checkeo de eliminación fallido, el item está referenciado"); logger.debug("Checkeo de eliminación fallido, el item está referenciado"); failedEvent = new DeleteVesselTrackingCheckFailedEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.CREATE_CANCELLED)) { logger.info("Enviando evento CreateVesselTrackingCancelledEvent para: " + source.getAggregateId()); logger.debug("Enviando evento CreateVesselTrackingCancelledEvent para: " + source.getAggregateId()); failedEvent = new CreateVesselTrackingCancelledEvent().buildFrom(source); } Loading @@ -195,13 +195,13 @@ public class VesselTrackingEventFactory { if (type.equals(VesselTrackingEventTypes.UPDATE_CANCELLED)) { logger.info("Creando evento UpdateVesselTrackingCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTrackingCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new UpdateVesselTrackingCancelledEvent().buildFrom(source); } if (type.equals(VesselTrackingEventTypes.DELETE_CANCELLED)) { logger.info("Creando evento DeleteVesselTrackingCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTrackingCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new DeleteVesselTrackingCancelledEvent().buildFrom(source); } Loading
vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltype/VesselTypeEventFactory.java +15 −15 Original line number Diff line number Diff line Loading @@ -36,40 +36,40 @@ public class VesselTypeEventFactory { if (type.equals(VesselTypeEventTypes.DELETE)) { logger.info("Creando evento DeleteVesselTypeEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTypeEvent para: " + source.getAggregateId()); return new DeleteVesselTypeEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_CHECKED)) { logger.info("Creando evento DeleteVesselTypeCheckedEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTypeCheckedEvent para: " + source.getAggregateId()); return new DeleteVesselTypeCheckedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.CREATE_CONFIRMED)) { logger.info("Creando evento CreateVesselTypeConfirmedEvent para: " + source.getAggregateId()); logger.debug("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()); logger.debug("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()); logger.debug("Creando evento DeleteVesselTypeConfirmedEvent para: " + source.getAggregateId()); return new DeleteVesselTypeConfirmedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETED)) { logger.info("Creando evento VesselTypeDeletedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTypeDeletedEvent para: " + source.getAggregateId()); return new VesselTypeDeletedEvent().buildFrom(source); } Loading @@ -82,12 +82,12 @@ public class VesselTypeEventFactory { VesselTypeEvent successfulEvent = null; if (type.equals(VesselTypeEventTypes.CREATED)) { logger.info("Creando evento VesselTypeCreatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTypeCreatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTypeCreatedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.UPDATED)) { logger.info("Creando evento VesselTypeUpdatedEvent para: " + source.getAggregateId()); logger.debug("Creando evento VesselTypeUpdatedEvent para: " + source.getAggregateId()); successfulEvent = new VesselTypeUpdatedEvent().buildFrom(source); } Loading @@ -107,29 +107,29 @@ public class VesselTypeEventFactory { if (type.equals(VesselTypeEventTypes.CREATE_FAILED)) { logger.info("No se pudo crear Vessel type en la vista"); logger.debug("No se pudo crear Vessel type en la vista"); failedEvent = new CreateVesselTypeFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.UPDATE_FAILED)) { logger.info("No se pudo modificar Vessel type en la vista"); logger.debug("No se pudo modificar Vessel type en la vista"); failedEvent = new UpdateVesselTypeFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_FAILED)) { logger.info("No se pudo eliminar Vessel type de la vista"); logger.debug("No se pudo eliminar Vessel type de la vista"); failedEvent = new DeleteVesselTypeFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_CHECK_FAILED)) { logger.info("Checkeo de eliminación fallido, el item está referenciado"); logger.debug("Checkeo de eliminación fallido, el item está referenciado"); failedEvent = new DeleteVesselTypeCheckFailedEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.CREATE_CANCELLED)) { logger.info("Enviando evento CreateVesselTypeCancelledEvent para: " + source.getAggregateId()); logger.debug("Enviando evento CreateVesselTypeCancelledEvent para: " + source.getAggregateId()); failedEvent = new CreateVesselTypeCancelledEvent().buildFrom(source); } Loading @@ -152,13 +152,13 @@ public class VesselTypeEventFactory { if (type.equals(VesselTypeEventTypes.UPDATE_CANCELLED)) { logger.info("Creando evento UpdateVesselTypeCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento UpdateVesselTypeCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new UpdateVesselTypeCancelledEvent().buildFrom(source); } if (type.equals(VesselTypeEventTypes.DELETE_CANCELLED)) { logger.info("Creando evento DeleteVesselTypeCancelledEvent para: " + source.getAggregateId()); logger.debug("Creando evento DeleteVesselTypeCancelledEvent para: " + source.getAggregateId()); cancelledEvent = new DeleteVesselTypeCancelledEvent().buildFrom(source); } Loading