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

Añade return al publicar error 

De esta manera no sigue ejecutando
parent 0216dd4b

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

+4 −0
Original line number Diff line number Diff line
@@ -61,6 +61,7 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
					"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()) {
@@ -84,6 +85,7 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {
@@ -108,6 +110,7 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {
@@ -131,6 +134,7 @@ public class VesselController extends DataController<Vessel, VesselDTO, Metadata 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {

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

+4 −0
Original line number Diff line number Diff line
@@ -60,6 +60,7 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
					+ " " + e.getMessage());

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

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

			return;

		}



		if (result.isSuccess()) {
@@ -84,6 +85,7 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {
@@ -109,6 +111,7 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {
@@ -133,6 +136,7 @@ public class VesselTrackingController extends GeoDataController<VesselTracking, 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {

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

+3 −0
Original line number Diff line number Diff line
@@ -59,6 +59,7 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {
@@ -83,6 +84,7 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {
@@ -107,6 +109,7 @@ public class VesselTypeController extends DataController<VesselType, VesselTypeD 
		} catch (Exception e) {

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

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

			return;

		}



		if (result.isSuccess()) {