Commit 9b165f7d authored by Noel Alonso's avatar Noel Alonso
Browse files

Se envía alertService a la base 

De esta forma se puede pasar envío de mensajes desde la base refactorizando
código.
parent f154d527

vessels-commands/src/main/java/es/redmic/vesselscommands/commands/VesselCommandHandler.java

+1 −1
Original line number Diff line number Diff line
@@ -90,7 +90,7 @@ public class VesselCommandHandler extends CommandHandler { 
					.serviceId(vessels_id_config)

					.stateStoreDir(state_store_vessels_dir)

					.topic(vessel_topic)

					.build());

					.build(), alertService);



		new VesselEventStreams(

				StreamConfig.Builder

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

+1 −1
Original line number Diff line number Diff line
@@ -80,7 +80,7 @@ public class VesselTypeCommandHandler extends CommandHandler { 
					.serviceId(vesseltypes_id_config)

					.stateStoreDir(state_store_vesseltypes_dir)

					.topic(vessel_type_topic)

					.build());

					.build(), alertService);



		new VesselTypeEventStreams(StreamConfig.Builder

				.bootstrapServers(bootstrapServers)

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

+3 −2
Original line number Diff line number Diff line 
package es.redmic.vesselscommands.statestore;



import es.redmic.brokerlib.alert.AlertService;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.commandslib.statestore.StateStore;

import es.redmic.commandslib.statestore.StreamConfig;



public class VesselStateStore extends StateStore {



	public VesselStateStore(StreamConfig config) {

		super(config);

	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/VesselTypeStateStore.java

+3 −2
Original line number Diff line number Diff line 
package es.redmic.vesselscommands.statestore;



import es.redmic.brokerlib.alert.AlertService;

import es.redmic.brokerlib.avro.common.Event;

import es.redmic.commandslib.statestore.StateStore;

import es.redmic.commandslib.statestore.StreamConfig;



public class VesselTypeStateStore extends StateStore {



	public VesselTypeStateStore(StreamConfig config) {

		super(config);

	public VesselTypeStateStore(StreamConfig config, AlertService alertService) {

		super(config, alertService);

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

		init();

	}

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselEventStreams.java

+1 −12
Original line number Diff line number Diff line
@@ -32,12 +32,9 @@ public class VesselEventStreams extends EventStreams { 


	private String vesselTypeTopic;



	private AlertService alertService;



	public VesselEventStreams(StreamConfig config, String vesselTypeTopic, AlertService alertService) {

		super(config);

		super(config, alertService);

		this.vesselTypeTopic = vesselTypeTopic;

		this.alertService = alertService;

		logger.info("Arrancado servicio de compensación de errores de edición y PostUpdate de Vessel con Id: "

				+ this.serviceId);

		init();
@@ -67,10 +64,6 @@ public class VesselEventStreams extends EventStreams { 
		assert confirmedEvent.getType().equals(VesselEventType.CREATE_VESSEL_CONFIRMED.name());



		if (!isSameSession(confirmedEvent, requestEvent)) {

			String message = "Recibido evento de petición con id de sessión diferente al evento de confirmación para item "

					+ confirmedEvent.getAggregateId();

			logger.error(message);

			alertService.errorAlert(confirmedEvent.getAggregateId(), message);

			return null;

		}
@@ -107,10 +100,6 @@ public class VesselEventStreams extends EventStreams { 
		assert confirmedEvent.getType().equals(VesselEventType.UPDATE_VESSEL_CONFIRMED.name());



		if (!isSameSession(confirmedEvent, requestEvent)) {

			String message = "Recibido evento de petición con id de sessión diferente al evento de confirmación para item "

					+ confirmedEvent.getAggregateId();

			logger.error(message);

			alertService.errorAlert(confirmedEvent.getAggregateId(), message);

			return null;

		}