Commit 02a9c090 authored by Noel Alonso's avatar Noel Alonso
Browse files

Elimina log no necesario

parent dc454f2d

vessels-view/src/main/java/es/redmic/vesselsview/controller/vessel/VesselController.java

+0 −19
Original line number Diff line number Diff line 
package es.redmic.vesselsview.controller.vessel;



import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.kafka.annotation.KafkaHandler;
@@ -31,8 +29,6 @@ import es.redmic.viewlib.data.controller.DataController; 
@KafkaListener(topics = "${broker.topic.vessel}")

public class VesselController extends DataController<Vessel, VesselDTO, MetadataQueryDTO> {



	private static Logger logger = LogManager.getLogger();



	@Value("${broker.topic.vessel}")

	private String vessel_topic;
@@ -50,22 +46,17 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
	@KafkaHandler

	public void listen(CreateVesselEvent event) {



		logger.info("Crear vessel");



		EventApplicationResult result = null;



		try {

			result = service.save(mapper.getMapperFacade().map(event.getVessel(), Vessel.class));

		} catch (Exception e) {

			logger.error(

					"Error al procesar CreateVesselEvent para vessel " + event.getAggregateId() + " " + e.getMessage());

			publishFailedEvent(VesselEventFactory.getEvent(event, VesselEventTypes.CREATE_FAILED,

					ExceptionType.INTERNAL_EXCEPTION.name(), null), vessel_topic);

			return;

		}



		if (result.isSuccess()) {

			logger.info("Vessel creado en la vista");

			publishConfirmedEvent(new CreateVesselConfirmedEvent().buildFrom(event), vessel_topic);

		} else {

			publishFailedEvent(VesselEventFactory.getEvent(event, VesselEventTypes.CREATE_FAILED,
@@ -76,8 +67,6 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
	@KafkaHandler

	public void listen(UpdateVesselEvent event) {



		logger.info("Modificar vessel");



		EventApplicationResult result = null;



		try {
@@ -89,7 +78,6 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
		}



		if (result.isSuccess()) {

			logger.info("Vessel modificado en la vista");

			publishConfirmedEvent(new UpdateVesselConfirmedEvent().buildFrom(event), vessel_topic);

		} else {

			publishFailedEvent(VesselEventFactory.getEvent(event, VesselEventTypes.UPDATE_FAILED,
@@ -100,8 +88,6 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
	@KafkaHandler

	public void listen(UpdateVesselTypeInVesselEvent event) {



		logger.info("Modificar vesseltype en vessel");



		EventApplicationResult result = null;



		try {
@@ -114,7 +100,6 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
		}



		if (result.isSuccess()) {

			logger.info("Vessel modificado en la vista");

			publishConfirmedEvent(new UpdateVesselConfirmedEvent().buildFrom(event), vessel_topic);

		} else {

			publishFailedEvent(VesselEventFactory.getEvent(event, VesselEventTypes.UPDATE_FAILED,
@@ -125,8 +110,6 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
	@KafkaHandler

	public void listen(DeleteVesselEvent event) {



		logger.info("Eliminar vessel");



		EventApplicationResult result = null;



		try {
@@ -138,8 +121,6 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
		}



		if (result.isSuccess()) {



			logger.info("Vessel eliminado de la vista");

			publishConfirmedEvent(new DeleteVesselConfirmedEvent().buildFrom(event), vessel_topic);

		} else {

			publishFailedEvent(VesselEventFactory.getEvent(event, VesselEventTypes.DELETE_FAILED,

vessels-view/src/main/java/es/redmic/vesselsview/controller/vesseltracking/VesselTrackingController.java

+0 −15
Original line number Diff line number Diff line 
package es.redmic.vesselsview.controller.vesseltracking;



import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.kafka.annotation.KafkaHandler;
@@ -28,8 +26,6 @@ import es.redmic.viewlib.geodata.controller.GeoDataController; 
@KafkaListener(topics = "${broker.topic.vessel-tracking}")

public class VesselTrackingController extends GeoDataController<VesselTracking, VesselTrackingDTO, DataQueryDTO> {



	private static Logger logger = LogManager.getLogger();



	@Value("${broker.topic.vessel-tracking}")

	private String vesseltracking_topic;
@@ -47,22 +43,17 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
	@KafkaHandler

	public void listen(CreateVesselTrackingEvent event) {



		logger.info("Crear vesselTracking");



		EventApplicationResult result = null;



		try {

			result = service.save(mapper.getMapperFacade().map(event.getVesselTracking(), VesselTracking.class));

		} catch (Exception e) {

			logger.error("Error al procesar CreateVesselTrackingEvent para vesselTracking " + event.getAggregateId()

					+ " " + e.getMessage());

			publishFailedEvent(VesselTrackingEventFactory.getEvent(event, VesselTrackingEventTypes.CREATE_FAILED,

					ExceptionType.INTERNAL_EXCEPTION.name(), null), vesseltracking_topic);

			return;

		}



		if (result.isSuccess()) {

			logger.info("VesselTracking creado en la vista");

			publishConfirmedEvent(VesselTrackingEventFactory.getEvent(event, VesselTrackingEventTypes.CREATE_CONFIRMED),

					vesseltracking_topic);

		} else {
@@ -74,8 +65,6 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
	@KafkaHandler

	public void listen(UpdateVesselTrackingEvent event) {



		logger.info("Modificar vesselTracking");



		EventApplicationResult result = null;



		try {
@@ -87,7 +76,6 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
		}



		if (result.isSuccess()) {

			logger.info("VesselTracking modificado en la vista");

			publishConfirmedEvent(VesselTrackingEventFactory.getEvent(event, VesselTrackingEventTypes.UPDATE_CONFIRMED),

					vesseltracking_topic);

		} else {
@@ -99,8 +87,6 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
	@KafkaHandler

	public void listen(DeleteVesselTrackingEvent event) {



		logger.info("Eliminar vesselTracking");



		EventApplicationResult result = null;



		try {
@@ -113,7 +99,6 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 


		if (result.isSuccess()) {



			logger.info("VesselTracking eliminado de la vista");

			publishConfirmedEvent(VesselTrackingEventFactory.getEvent(event, VesselTrackingEventTypes.DELETE_CONFIRMED),

					vesseltracking_topic);

		} else {

vessels-view/src/main/java/es/redmic/vesselsview/controller/vesseltype/VesselTypeController.java

+0 −16
Original line number Diff line number Diff line 
package es.redmic.vesselsview.controller.vesseltype;



import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.kafka.annotation.KafkaHandler;
@@ -31,8 +29,6 @@ import es.redmic.viewlib.data.controller.DataController; 
@KafkaListener(topics = "${broker.topic.vessel-type}")

public class VesselTypeController extends DataController<VesselType, VesselTypeDTO, SimpleQueryDTO> {



	private static Logger logger = LogManager.getLogger();



	@Value("${broker.topic.vessel-type}")

	private String vessel_type_topic;
@@ -50,8 +46,6 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
	@KafkaHandler

	public void listen(CreateVesselTypeEvent event) {



		logger.info("Crear vessel type");



		EventApplicationResult result = null;



		try {
@@ -63,8 +57,6 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
		}



		if (result.isSuccess()) {



			logger.info("Vessel type creado de la vista");

			publishConfirmedEvent(new CreateVesselTypeConfirmedEvent().buildFrom(event), vessel_type_topic);

		} else {

			publishFailedEvent(VesselTypeEventFactory.getEvent(event, VesselTypeEventTypes.CREATE_FAILED,
@@ -75,8 +67,6 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
	@KafkaHandler

	public void listen(UpdateVesselTypeEvent event) {



		logger.info("Modificar vessel type");



		EventApplicationResult result = null;



		try {
@@ -88,8 +78,6 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
		}



		if (result.isSuccess()) {



			logger.info("Vessel type modificado en la vista");

			publishConfirmedEvent(new UpdateVesselTypeConfirmedEvent().buildFrom(event), vessel_type_topic);

		} else {

			publishFailedEvent(VesselTypeEventFactory.getEvent(event, VesselTypeEventTypes.UPDATE_FAILED,
@@ -100,8 +88,6 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
	@KafkaHandler

	public void listen(DeleteVesselTypeEvent event) {



		logger.info("Eliminar vessel type");



		EventApplicationResult result = null;



		try {
@@ -113,8 +99,6 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
		}



		if (result.isSuccess()) {



			logger.info("Vessel type eliminado de la vista");

			publishConfirmedEvent(new DeleteVesselTypeConfirmedEvent().buildFrom(event), vessel_type_topic);

		} else {

			publishFailedEvent(VesselTypeEventFactory.getEvent(event, VesselTypeEventTypes.DELETE_FAILED,