Commit fce62373 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade eventos para modificaciones parciales

parent 486ea846

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/partialupdate/vessel/AggregationVesselInVesselTrackingPostUpdateEvent.java

0 → 100644
+43 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltracking.partialupdate.vessel;



import java.util.UUID;



import org.apache.avro.Schema;



import es.redmic.vesselslib.dto.vessel.VesselDTO;

import es.redmic.vesselslib.events.vessel.common.VesselEvent;



public class AggregationVesselInVesselTrackingPostUpdateEvent extends VesselEvent {



	// @formatter:off



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

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

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

				+ getVesselEventSchema() + ","

				+ getEventBaseSchema() + "]}");

		// @formatter:on



	static String type = "AGGREGATION";



	public AggregationVesselInVesselTrackingPostUpdateEvent() {

		super(type);

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

	}



	public AggregationVesselInVesselTrackingPostUpdateEvent(String type) {

		super(type);

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

	}



	public AggregationVesselInVesselTrackingPostUpdateEvent(String type, VesselDTO vessel) {

		super(type);

		this.setVessel(vessel);

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

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/partialupdate/vessel/UpdateVesselInVesselTrackingEvent.java

0 → 100644
+39 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltracking.partialupdate.vessel;



import java.util.UUID;



import org.apache.avro.Schema;



import es.redmic.vesselslib.dto.vessel.VesselDTO;

import es.redmic.vesselslib.events.vessel.common.VesselEvent;

import es.redmic.vesselslib.events.vesseltracking.VesselTrackingEventTypes;



public class UpdateVesselInVesselTrackingEvent extends VesselEvent {



	// @formatter:off



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

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

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

				+ getVesselEventSchema() + ","

				+ getEventBaseSchema() + "]}");

		// @formatter:on



	static String type = VesselTrackingEventTypes.UPDATE_VESSEL;



	public UpdateVesselInVesselTrackingEvent() {

		super(type);

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

	}



	public UpdateVesselInVesselTrackingEvent(VesselDTO vessel) {

		super(type);

		this.setVessel(vessel);

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

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}