Commit 01967c55 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade nuevos eventos al ciclo delete + tests

parent 97fc9e09

vessels-lib/src/main/java/es/redmic/vesselslib/events/vessel/delete/DeleteVesselCheckFailedEvent.java

0 → 100644
+29 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vessel.delete;



import org.apache.avro.Schema;



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

import es.redmic.vesselslib.events.vessel.VesselEventTypes;



public class DeleteVesselCheckFailedEvent extends EventError {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

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

				+ "\"namespace\":\"es.redmic.vesselslib.events.vessel.delete\",\"fields\":["

		+ getFailEventSchema() + ","

		+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselEventTypes.DELETE_CHECK_FAILED;



	public DeleteVesselCheckFailedEvent() {

		super(type);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vessel/delete/DeleteVesselCheckedEvent.java

0 → 100644
+28 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vessel.delete;



import org.apache.avro.Schema;



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

import es.redmic.vesselslib.events.vessel.VesselEventTypes;



public class DeleteVesselCheckedEvent extends SimpleEvent {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

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

				+ "\"namespace\":\"es.redmic.vesselslib.events.vessel.delete\",\"fields\":["

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselEventTypes.DELETE_CHECKED;



	public DeleteVesselCheckedEvent() {

		super(type);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltype/delete/DeleteVesselTypeCheckFailedEvent.java

0 → 100644
+29 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltype.delete;



import org.apache.avro.Schema;



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

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



public class DeleteVesselTypeCheckFailedEvent extends EventError {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

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

				+ "\"namespace\":\"es.redmic.vesselslib.events.vesseltype.delete\",\"fields\":["

			+ getFailEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTypeEventTypes.DELETE_CHECK_FAILED;



	public DeleteVesselTypeCheckFailedEvent() {

		super(type);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltype/delete/DeleteVesselTypeCheckedEvent.java

0 → 100644
+28 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltype.delete;



import org.apache.avro.Schema;



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

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



public class DeleteVesselTypeCheckedEvent extends SimpleEvent {



	// @formatter:off



	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"

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

				+ "\"namespace\":\"es.redmic.vesselslib.events.vesseltype.delete\",\"fields\":["

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTypeEventTypes.DELETE_CHECKED;



	public DeleteVesselTypeCheckedEvent() {

		super(type);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/test/java/es/redmic/vesselslib/unit/events/VesselEventsCheckAvroSchemaTest.java

+28 −0
Original line number Diff line number Diff line
@@ -15,6 +15,8 @@ import es.redmic.vesselslib.events.vessel.create.CreateVesselEvent; 
import es.redmic.vesselslib.events.vessel.create.CreateVesselFailedEvent;

import es.redmic.vesselslib.events.vessel.create.VesselCreatedEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCancelledEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckFailedEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselCheckedEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselConfirmedEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselEvent;

import es.redmic.vesselslib.events.vessel.delete.DeleteVesselFailedEvent;
@@ -177,6 +179,32 @@ public class VesselEventsCheckAvroSchemaTest extends VesselAvroBaseTest { 
		assertEquals(result, event);

	}



	@Test

	public void DeleteVesselCheckedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		DeleteVesselCheckedEvent event = VesselDataUtil.getDeleteVesselCheckedEvent();



		Object result = serializerAndDeserializer(event);



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

				DeleteVesselCheckedEvent.class.isInstance(result));



		assertEquals(result, event);

	}



	@Test

	public void DeleteVesselCheckFailedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {



		DeleteVesselCheckFailedEvent event = VesselDataUtil.getDeleteVesselCheckFailedEvent();



		Object result = serializerAndDeserializer(event);



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

				DeleteVesselCheckFailedEvent.class.isInstance(result));



		assertEquals(result, event);

	}



	@Test

	public void DeleteVesselConfirmedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {