Commit 0d7e0082 authored by Noel Alonso's avatar Noel Alonso
Browse files

Cambia referencias a clases reubicadas

parent a2d9b191

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

+2 −2
Original line number Diff line number Diff line
@@ -2,8 +2,8 @@ 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;

import es.redmic.commandslib.streaming.common.StreamConfig;

import es.redmic.commandslib.streaming.statestore.StateStore;



public class VesselStateStore extends StateStore {

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

+2 −2
Original line number Diff line number Diff line
@@ -2,8 +2,8 @@ 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;

import es.redmic.commandslib.streaming.common.StreamConfig;

import es.redmic.commandslib.streaming.statestore.StateStore;



public class VesselTypeStateStore extends StateStore {

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

+4 −4
Original line number Diff line number Diff line
@@ -7,8 +7,8 @@ import org.apache.kafka.streams.kstream.KTable; 
import es.redmic.brokerlib.alert.AlertService;

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

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

import es.redmic.commandslib.statestore.StreamConfig;

import es.redmic.commandslib.streams.EventStreams;

import es.redmic.commandslib.streaming.common.StreamConfig;

import es.redmic.commandslib.streaming.streams.EventSourcingStreams;

import es.redmic.vesselslib.dto.VesselTypeDTO;

import es.redmic.vesselslib.events.vesseltype.VesselTypeEventTypes;

import es.redmic.vesselslib.events.vesseltype.common.VesselTypeEvent;
@@ -17,11 +17,11 @@ import es.redmic.vesselslib.events.vesseltype.delete.DeleteVesselTypeCancelledEv 
import es.redmic.vesselslib.events.vesseltype.update.UpdateVesselTypeCancelledEvent;

import es.redmic.vesselslib.events.vesseltype.update.VesselTypeUpdatedEvent;



public class VesselTypeEventStreams extends EventStreams {

public class VesselTypeEventStreams extends EventSourcingStreams {



	public VesselTypeEventStreams(StreamConfig config, AlertService alertService) {

		super(config, alertService);

		logger.info("Arrancado servicio de compensación de errores de edición de VesselType con Id: " + this.serviceId);

		logger.info("Arrancado servicio de streaming para event sourcing de VesselType con Id: " + this.serviceId);

		init();

	}