Commit d6447a06 authored by Noel Alonso's avatar Noel Alonso
Browse files

Comprueba si el themeInspire está actualizado 

Envía evento de postupdate solo para las capas que no tengan
themeInspire actualizado
parent d496e9af

atlas-commands/src/main/java/es/redmic/atlascommands/handler/LayerCommandHandler.java

+10 −4
Original line number Diff line number Diff line
@@ -41,6 +41,7 @@ import es.redmic.atlascommands.config.UserService; 
import es.redmic.atlascommands.statestore.LayerStateStore;

import es.redmic.atlascommands.streams.LayerEventStreams;

import es.redmic.atlaslib.dto.layer.LayerDTO;

import es.redmic.atlaslib.dto.themeinspire.ThemeInspireDTO;

import es.redmic.atlaslib.events.layer.LayerEventFactory;

import es.redmic.atlaslib.events.layer.LayerEventTypes;

import es.redmic.atlaslib.events.layer.common.LayerEvent;
@@ -369,13 +370,18 @@ public class LayerCommandHandler extends CommandHandler { 


			Event layerEvent = next.value;



			if (LayerEventTypes.isSnapshot(layerEvent.getType()) && ((LayerEvent) layerEvent).getLayer()

					.getThemeInspire().getId().equals(event.getThemeInspire().getId())) {

			if (LayerEventTypes.isSnapshot(layerEvent.getType())) {



				ThemeInspireDTO themeInspire = ((LayerEvent) layerEvent).getLayer().getThemeInspire();



				if (themeInspire.getId().equals(event.getThemeInspire().getId())

						&& !themeInspire.equals(event.getThemeInspire())) {



					publishToKafka(LayerEventFactory.getEvent(layerEvent, event, LayerEventTypes.UPDATE_THEMEINSPIRE),

							layerTopic);

				}

			}

		}

		iteratble.close();

	}

}