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

Añade eventos de edición parcial + tests

parent e7e8f895
Loading
Loading
Loading
Loading
+36 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.partialupdate.vesseltype;

import org.apache.avro.Schema;

import es.redmic.vesselslib.dto.VesselTypeDTO;
import es.redmic.vesselslib.events.vessel.VesselEventTypes;
import es.redmic.vesselslib.events.vesseltype.common.VesselTypeCancelledEvent;

public class UpdateVesselTypeInVesselCancelledEvent extends VesselTypeCancelledEvent {

	// @formatter:off

	public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"
		+ "\"type\":\"record\",\"name\":\"UpdateVesselTypeInVesselCancelledEvent\","
				+ "\"namespace\":\"es.redmic.vesselslib.events.vessel.partialupdate.vesseltype\",\"fields\":["
			+ getVesselTypeEventSchema() + ","
			+ getFailEventSchema() + ","
			+ getEventBaseSchema() + "]}");
	// @formatter:on

	static String type = VesselEventTypes.UPDATE_VESSELTYPE_CANCELLED;

	public UpdateVesselTypeInVesselCancelledEvent() {
		super(type);
	}

	public UpdateVesselTypeInVesselCancelledEvent(VesselTypeDTO vesselType) {
		super(type);
		this.setVesselType(vesselType);
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
 No newline at end of file
+28 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.partialupdate.vesseltype;

import org.apache.avro.Schema;

import es.redmic.brokerlib.avro.common.SimpleEvent;
import es.redmic.vesselslib.events.vessel.VesselEventTypes;

public class UpdateVesselTypeInVesselConfirmedEvent extends SimpleEvent {

	// @formatter:off

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

	static String type = VesselEventTypes.UPDATE_VESSELTYPE_CONFIRMED;

	public UpdateVesselTypeInVesselConfirmedEvent() {
		super(type);
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
 No newline at end of file
+39 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.partialupdate.vesseltype;

import java.util.UUID;

import org.apache.avro.Schema;

import es.redmic.vesselslib.dto.VesselTypeDTO;
import es.redmic.vesselslib.events.vessel.VesselEventTypes;
import es.redmic.vesselslib.events.vesseltype.common.VesselTypeEvent;

public class UpdateVesselTypeInVesselEvent extends VesselTypeEvent {

	// @formatter:off

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

	static String type = VesselEventTypes.UPDATE_VESSELTYPE;

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

	public UpdateVesselTypeInVesselEvent(VesselTypeDTO vesselType) {
		super(type);
		this.setVesselType(vesselType);
		setSessionId(UUID.randomUUID().toString());
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
+29 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.partialupdate.vesseltype;

import org.apache.avro.Schema;

import es.redmic.brokerlib.avro.common.EventError;
import es.redmic.vesselslib.events.vessel.VesselEventTypes;

public class UpdateVesselTypeInVesselFailedEvent extends EventError {

	// @formatter:off

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

	static String type = VesselEventTypes.UPDATE_VESSELTYPE_FAILED;

	public UpdateVesselTypeInVesselFailedEvent() {
		super(type);
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
 No newline at end of file
+35 −0
Original line number Diff line number Diff line
package es.redmic.vesselslib.events.vessel.partialupdate.vesseltype;

import org.apache.avro.Schema;

import es.redmic.vesselslib.dto.VesselTypeDTO;
import es.redmic.vesselslib.events.vessel.VesselEventTypes;
import es.redmic.vesselslib.events.vesseltype.common.VesselTypeEvent;

public class VesselTypeInVesselUpdatedEvent extends VesselTypeEvent {

	// @formatter:off

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

	static String type = VesselEventTypes.VESSELTYPE_UPDATED;

	public VesselTypeInVesselUpdatedEvent() {
		super(type);
	}

	public VesselTypeInVesselUpdatedEvent(VesselTypeDTO vesselType) {
		super(type);
		this.setVesselType(vesselType);
	}

	@Override
	public Schema getSchema() {
		return SCHEMA$;
	}
}
 No newline at end of file
Loading