Commit 5f2f14df authored by Noel Alonso's avatar Noel Alonso
Browse files

Elimina parentId del evento 

Se ha optado por no enviar parentId desde el cliente, en su defecto, se
realiza una búsqueda del elemento antes de borrarlo para obtener el
parentId
parent f8f8c989

atlas-lib/src/main/java/es/redmic/atlaslib/events/layer/delete/DeleteLayerEvent.java

+0 −69
Original line number Diff line number Diff line
@@ -23,8 +23,6 @@ package es.redmic.atlaslib.events.layer.delete; 
import java.util.UUID;



import org.apache.avro.Schema;

import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



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

import es.redmic.brokerlib.avro.common.SimpleEvent;
@@ -36,85 +34,18 @@ public class DeleteLayerEvent extends SimpleEvent { 
	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

		+ "\"type\":\"record\",\"name\":\"DeleteLayerEvent\","

				+ "\"namespace\":\"es.redmic.atlaslib.events.layer.delete\",\"fields\":["

			+ "{\"name\":\"parentId\",\"type\":\"string\"},"

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = LayerEventTypes.DELETE;



	private String parentId;



	public DeleteLayerEvent() {

		super(type);

		setSessionId(UUID.randomUUID().toString());

	}



	public String getParentId() {

		return parentId;

	}



	public void setParentId(String parentId) {

		this.parentId = parentId;

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}



	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getParentId();

		case 1:

			return getAggregateId();

		case 2:

			return getVersion();

		case 3:

			return getType();

		case 4:

			return getDate().getMillis();

		case 5:

			return getSessionId();

		case 6:

			return getUserId();

		case 7:

			return getId();

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}



	@Override

	public void put(int field$, Object value$) {

		switch (field$) {

		case 0:

			setParentId(value$.toString());

			break;

		case 1:

			setAggregateId(value$.toString());

			break;

		case 2:

			setVersion((java.lang.Integer) value$);

			break;

		case 3:

			setType(value$.toString());

			break;

		case 4:

			setDate(new DateTime(value$, DateTimeZone.UTC));

			break;

		case 5:

			setSessionId(value$.toString());

			break;

		case 6:

			setUserId(value$.toString());

			break;

		case 7:

			setId(value$.toString());

			break;

		default:

			throw new org.apache.avro.AvroRuntimeException("Bad index");

		}

	}

}

atlas-lib/src/test/java/es/redmic/atlaslib/unit/events/layer/LayerEventsCheckAvroSchemaTest.java

+0 −2
Original line number Diff line number Diff line
@@ -189,8 +189,6 @@ public class LayerEventsCheckAvroSchemaTest extends AtlasAvroBaseTest { 


		DeleteLayerEvent event = LayerDataUtil.getDeleteEvent();



		event.setParentId("category-1234");



		Object result = serializerAndDeserializer(event);



		assertTrue("El objeto obtenido debe ser una instancia de DeleteLayerEvent",