Commit 486ea846 authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade eventos para modificar vesselTracking

parent c74ee453

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/update/EnrichUpdateVesselTrackingEvent.java

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



import java.util.UUID;



import org.apache.avro.Schema;



import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;

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

import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingEvent;



public class EnrichUpdateVesselTrackingEvent extends VesselTrackingEvent {



	// @formatter:off



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

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

				+ "\"namespace\":\"es.redmic.vesselTrackingslib.events.vesseltracking.update\",\"fields\":["

			+ getVesselTrackingEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTrackingEventTypes.ENRICH_UPDATE;



	public EnrichUpdateVesselTrackingEvent() {

		super(type);

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

	}



	public EnrichUpdateVesselTrackingEvent(VesselTrackingDTO vesselTracking) {

		super(type);

		this.setVesselTracking(vesselTracking);

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

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/update/UpdateVesselTrackingCancelledEvent.java

0 → 100644
+36 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltracking.update;



import org.apache.avro.Schema;



import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;

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

import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingCancelledEvent;



public class UpdateVesselTrackingCancelledEvent extends VesselTrackingCancelledEvent {



	// @formatter:off



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

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

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

			+ getVesselTrackingEventSchema() + ","

			+ getFailEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTrackingEventTypes.UPDATE_CANCELLED;



	public UpdateVesselTrackingCancelledEvent() {

		super(type);

	}



	public UpdateVesselTrackingCancelledEvent(VesselTrackingDTO vesselTracking) {

		super(type);

		this.setVesselTracking(vesselTracking);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/update/UpdateVesselTrackingConfirmedEvent.java

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



import org.apache.avro.Schema;



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

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



public class UpdateVesselTrackingConfirmedEvent extends SimpleEvent {



	// @formatter:off



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

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

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

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTrackingEventTypes.UPDATE_CONFIRMED;



	public UpdateVesselTrackingConfirmedEvent() {

		super(type);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/update/UpdateVesselTrackingEnrichedEvent.java

0 → 100644
+35 −0
Original line number Diff line number Diff line 
package es.redmic.vesselslib.events.vesseltracking.update;



import org.apache.avro.Schema;



import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;

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

import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingEvent;



public class UpdateVesselTrackingEnrichedEvent extends VesselTrackingEvent {



	// @formatter:off



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

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

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

			+ getVesselTrackingEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTrackingEventTypes.UPDATE_ENRICHED;



	public UpdateVesselTrackingEnrichedEvent() {

		super(type);

	}



	public UpdateVesselTrackingEnrichedEvent(VesselTrackingDTO vesselTracking) {

		super(type);

		this.setVesselTracking(vesselTracking);

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/update/UpdateVesselTrackingEvent.java

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



import java.util.UUID;



import org.apache.avro.Schema;



import es.redmic.vesselslib.dto.tracking.VesselTrackingDTO;

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

import es.redmic.vesselslib.events.vesseltracking.common.VesselTrackingEvent;



public class UpdateVesselTrackingEvent extends VesselTrackingEvent {



	// @formatter:off



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

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

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

			+ getVesselTrackingEventSchema() + ","

			+ getEventBaseSchema() + "]}");

	// @formatter:on



	static String type = VesselTrackingEventTypes.UPDATE;



	public UpdateVesselTrackingEvent() {

		super(type);

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

	}



	public UpdateVesselTrackingEvent(VesselTrackingDTO vesselTracking) {

		super(type);

		this.setVesselTracking(vesselTracking);

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

	}



	@Override

	public Schema getSchema() {

		return SCHEMA$;

	}

}