Commit 7bc964d8 authored by Noel Alonso's avatar Noel Alonso
Browse files

Arregla problema al agregar evento de cancelación

parent 3ec824d8
Loading
Loading
Loading
Loading
+3 −2
Original line number Diff line number Diff line
@@ -36,6 +36,7 @@ import es.redmic.atlaslib.events.category.delete.CheckDeleteCategoryEvent;
import es.redmic.atlaslib.events.category.update.UpdateCategoryEvent;
import es.redmic.brokerlib.avro.common.Event;
import es.redmic.commandslib.aggregate.Aggregate;
import es.redmic.commandslib.exceptions.ItemLockedException;

public class CategoryAggregate extends Aggregate {

@@ -153,13 +154,13 @@ public class CategoryAggregate extends Aggregate {
			apply((CategoryCancelledEvent) event);
			break;
		default:
			logger.debug("Evento no manejado ", event.getType());
			throw new ItemLockedException("id", event.getAggregateId());
		}
	}

	public void apply(CreateCategoryCancelledEvent event) {
		this.deleted = true;
		apply(event);
		super.apply(event);
	}

	public void apply(CategoryDeletedEvent event) {
+3 −2
Original line number Diff line number Diff line
@@ -41,6 +41,7 @@ import es.redmic.atlaslib.events.layer.update.EnrichUpdateLayerEvent;
import es.redmic.atlaslib.events.layer.update.UpdateLayerEvent;
import es.redmic.brokerlib.avro.common.Event;
import es.redmic.commandslib.aggregate.Aggregate;
import es.redmic.commandslib.exceptions.ItemLockedException;

public class LayerAggregate extends Aggregate {

@@ -196,13 +197,13 @@ public class LayerAggregate extends Aggregate {
			apply((LayerCancelledEvent) event);
			break;
		default:
			logger.debug("Evento no manejado ", event.getType());
			throw new ItemLockedException("id", event.getAggregateId());
		}
	}

	public void apply(CreateLayerCancelledEvent event) {
		this.deleted = true;
		apply(event);
		super.apply(event);
	}

	public void apply(LayerDeletedEvent event) {
+3 −2
Original line number Diff line number Diff line
@@ -35,6 +35,7 @@ import es.redmic.atlaslib.events.themeinspire.delete.ThemeInspireDeletedEvent;
import es.redmic.atlaslib.events.themeinspire.update.UpdateThemeInspireEvent;
import es.redmic.brokerlib.avro.common.Event;
import es.redmic.commandslib.aggregate.Aggregate;
import es.redmic.commandslib.exceptions.ItemLockedException;

public class ThemeInspireAggregate extends Aggregate {

@@ -152,13 +153,13 @@ public class ThemeInspireAggregate extends Aggregate {
			apply((ThemeInspireCancelledEvent) event);
			break;
		default:
			logger.debug("Evento no manejado ", event.getType());
			throw new ItemLockedException("id", event.getAggregateId());
		}
	}

	public void apply(CreateThemeInspireCancelledEvent event) {
		this.deleted = true;
		apply(event);
		super.apply(event);
	}

	public void apply(ThemeInspireDeletedEvent event) {