Commit 66cf4a58 authored by Noel Alonso's avatar Noel Alonso
Browse files

Elimina restos de implementación de postUpdate

parent 8193226a
Loading
Loading
Loading
Loading
+1 −4
Original line number Diff line number Diff line
@@ -75,9 +75,6 @@ public class ThemeInspireCommandHandler extends CommandHandler {
	@Value("${broker.topic.theme.inspire.updated}")
	private String themeInspireUpdatedTopic;

	@Value("${broker.topic.atlas.agg.by.themeinspire}")
	private String atlasAggByThemeInspireTopic;

	@Value("${broker.state.store.themeinspire.dir}")
	private String stateStoreThemeInspireDir;

@@ -122,7 +119,7 @@ public class ThemeInspireCommandHandler extends CommandHandler {
				config
					.serviceId(themeInspireEventsStreamId)
					.windowsTime(streamWindowsTime)
					.build(), atlasAggByThemeInspireTopic, alertService);
					.build(), alertService);
		
		// @formatter:on
	}
+0 −9
Original line number Diff line number Diff line
@@ -272,15 +272,6 @@ public class LayerEventStreams extends EventSourcingStreams {
		// En este caso no hay modificaciones parciales
	}

	/**
	 * Función para procesar modificaciones de referencias
	 */

	@Override
	protected void processPostUpdateStream(KStream<String, Event> events) {
		// En este caso no hay modificación de relaciones
	}

	@Override
	protected void processExtraStreams(KStream<String, Event> events, KStream<String, Event> snapshotEvents) {

+0 −3
Original line number Diff line number Diff line
@@ -81,9 +81,6 @@ broker.topic.layer=layer
#topic del broker para enviar/recibir eventos de theme inspire
broker.topic.theme-inspire=theme-inspire

# topic para aggregar layers por themeinspire
broker.topic.atlas.agg.by.themeinspire=atlas-agg-by-theme-inspire

#topic para enviar eventos de themeinspire modificados para postupdate
broker.topic.theme.inspire.updated=theme-inspire-updated

+0 −62
Original line number Diff line number Diff line
package es.redmic.atlaslib.events.layer.partialupdate.themeinspire;

/*-
 * #%L
 * Atlas-lib
 * %%
 * Copyright (C) 2019 REDMIC Project / Server
 * %%
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 *      http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 * #L%
 */

import java.util.UUID;

import org.apache.avro.Schema;

import es.redmic.atlaslib.dto.themeinspire.ThemeInspireDTO;
import es.redmic.atlaslib.events.themeinspire.common.ThemeInspireEvent;

public class AggregationThemeInspireInLayerPostUpdateEvent extends ThemeInspireEvent {

	// @formatter:off

	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"
		+ "\"type\":\"record\",\"name\":\"AggregationThemeInspireInLayerPostUpdateEvent\","
				+ "\"namespace\":\"es.redmic.atlaslib.events.atlas.partialupdate.themeinspire\",\"fields\":["
			+ getThemeInspireEventSchema() + ","
			+ getEventBaseSchema() + "]}");
	// @formatter:on

	static String type = "AGGREGATION";

	public AggregationThemeInspireInLayerPostUpdateEvent() {
		this(type);
	}

	public AggregationThemeInspireInLayerPostUpdateEvent(String type) {
		super(type);
		setSessionId(UUID.randomUUID().toString());
	}

	public AggregationThemeInspireInLayerPostUpdateEvent(String type, ThemeInspireDTO themeInspire) {
		this(type);
		this.setThemeInspire(themeInspire);
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}

}