Commit 802634a6 authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia nivel de log para mensajes de depuración

parent 84156cd6

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

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


		if (cmd.getVessel().getType() != null) {



			logger.info("Creando evento para enriquecer Vessel");

			logger.debug("Creando evento para enriquecer Vessel");

			evt = new EnrichCreateVesselEvent(cmd.getVessel());

		} else {

			logger.info("Creando evento para crear Vessel. Enriquecimiento descartado");

			logger.debug("Creando evento para crear Vessel. Enriquecimiento descartado");

			evt = new CreateVesselEvent(cmd.getVessel());

		}
@@ -72,10 +72,10 @@ public class VesselAggregate extends Aggregate { 


		if (cmd.getVessel().getType() != null) {



			logger.info("Creando evento para enriquecer Vessel");

			logger.debug("Creando evento para enriquecer Vessel");

			evt = new EnrichUpdateVesselEvent(cmd.getVessel());

		} else {

			logger.info("Creando evento para modificar Vessel. Enriquecimiento descartado");

			logger.debug("Creando evento para modificar Vessel. Enriquecimiento descartado");

			evt = new UpdateVesselEvent(cmd.getVessel());

		}

vessels-commands/src/main/java/es/redmic/vesselscommands/handler/VesselTrackingCommandHandler.java

+6 −6
Original line number Diff line number Diff line
@@ -209,7 +209,7 @@ public class VesselTrackingCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(VesselTrackingCreatedEvent event) {



		logger.info("VesselTracking creado " + event.getAggregateId());

		logger.debug("VesselTracking creado " + event.getAggregateId());



		// El evento Creado se envió desde el stream
@@ -227,7 +227,7 @@ public class VesselTrackingCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(VesselTrackingUpdatedEvent event) {



		logger.info("VesselTracking modificado " + event.getAggregateId());

		logger.debug("VesselTracking modificado " + event.getAggregateId());



		// El evento Modificado se envió desde el stream
@@ -244,7 +244,7 @@ public class VesselTrackingCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(VesselTrackingDeletedEvent event) {



		logger.info("VesselTracking eliminado " + event.getAggregateId());

		logger.debug("VesselTracking eliminado " + event.getAggregateId());



		resolveCommand(event.getSessionId());

	}
@@ -259,7 +259,7 @@ public class VesselTrackingCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(CreateVesselTrackingCancelledEvent event) {



		logger.info("Error creando VesselTracking " + event.getAggregateId());

		logger.debug("Error creando VesselTracking " + event.getAggregateId());



		resolveCommand(event.getSessionId(),

				ExceptionFactory.getException(event.getExceptionType(), event.getArguments()));
@@ -268,7 +268,7 @@ public class VesselTrackingCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(UpdateVesselTrackingCancelledEvent event) {



		logger.info("Error modificando VesselTracking " + event.getAggregateId());

		logger.debug("Error modificando VesselTracking " + event.getAggregateId());



		// El evento Cancelled se envía desde el stream
@@ -279,7 +279,7 @@ public class VesselTrackingCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(DeleteVesselTrackingCancelledEvent event) {



		logger.info("Error eliminando VesselTracking " + event.getAggregateId());

		logger.debug("Error eliminando VesselTracking " + event.getAggregateId());



		// El evento Cancelled se envía desde el stream

vessels-commands/src/main/java/es/redmic/vesselscommands/handler/VesselTypeCommandHandler.java

+6 −6
Original line number Diff line number Diff line
@@ -196,7 +196,7 @@ public class VesselTypeCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(VesselTypeCreatedEvent event) {



		logger.info("VesselType creado " + event.getAggregateId());

		logger.debug("VesselType creado " + event.getAggregateId());



		// El evento Creado se envía desde el stream
@@ -206,7 +206,7 @@ public class VesselTypeCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(VesselTypeUpdatedEvent event) {



		logger.info("VesselType modificado " + event.getAggregateId());

		logger.debug("VesselType modificado " + event.getAggregateId());



		// Envía los editados satisfactoriamente para tenerlos en cuenta en el

		// postupdate
@@ -232,7 +232,7 @@ public class VesselTypeCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(VesselTypeDeletedEvent event) {



		logger.info("VesselType eliminado " + event.getAggregateId());

		logger.debug("VesselType eliminado " + event.getAggregateId());



		resolveCommand(event.getSessionId());

	}
@@ -247,7 +247,7 @@ public class VesselTypeCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(CreateVesselTypeCancelledEvent event) {



		logger.info("Error creando VesselType " + event.getAggregateId());

		logger.debug("Error creando VesselType " + event.getAggregateId());



		resolveCommand(event.getSessionId(),

				ExceptionFactory.getException(event.getExceptionType(), event.getArguments()));
@@ -256,7 +256,7 @@ public class VesselTypeCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(UpdateVesselTypeCancelledEvent event) {



		logger.info("Error modificando VesselType " + event.getAggregateId());

		logger.debug("Error modificando VesselType " + event.getAggregateId());



		// El evento Cancelled se envía desde el stream
@@ -274,7 +274,7 @@ public class VesselTypeCommandHandler extends CommandHandler { 
	@KafkaHandler

	private void listen(DeleteVesselTypeCancelledEvent event) {



		logger.info("Error eliminando VesselType " + event.getAggregateId());

		logger.debug("Error eliminando VesselType " + event.getAggregateId());



		// El evento Cancelled se envía desde el stream

vessels-commands/src/main/java/es/redmic/vesselscommands/statestore/VesselStateStore.java

+0 −1
Original line number Diff line number Diff line
@@ -9,7 +9,6 @@ public class VesselStateStore extends StateStore { 


	public VesselStateStore(StreamConfig config, AlertService alertService) {

		super(config, alertService);

		logger.info("Arrancado servicio VesselStateStore con Id: " + this.serviceId);

		init();

	}

vessels-commands/src/main/java/es/redmic/vesselscommands/statestore/VesselTrackingStateStore.java

+0 −1
Original line number Diff line number Diff line
@@ -9,7 +9,6 @@ public class VesselTrackingStateStore extends StateStore { 


	public VesselTrackingStateStore(StreamConfig config, AlertService alertService) {

		super(config, alertService);

		logger.info("Arrancado servicio VesselTrackingStateStore con Id: " + this.serviceId);

		init();

	}