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

Crea eventos comunes de vesselTracking

parent ad70968f

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/common/VesselTrackingCancelledEvent.java

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



import java.util.Map;



import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



import com.fasterxml.jackson.annotation.JsonIgnore;



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

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



public abstract class VesselTrackingCancelledEvent extends EventError {



	private VesselTrackingDTO vesselTracking;



	public VesselTrackingCancelledEvent(String type) {

		super(type);

	}



	public VesselTrackingDTO getVesselTracking() {

		return vesselTracking;

	}



	public void setVesselTracking(VesselTrackingDTO vesselTracking) {

		this.vesselTracking = vesselTracking;

	}



	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getVesselTracking();

		case 1:

			return getExceptionType();

		case 2:

			return getArguments();

		case 3:

			return getAggregateId();

		case 4:

			return getVersion();

		case 5:

			return getType();

		case 6:

			return getDate().getMillis();

		case 7:

			return getSessionId();

		case 8:

			return getUserId();

		case 9:

			return getId();

		default:

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

		}

	}



	@SuppressWarnings("rawtypes")

	@Override

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

		switch (field$) {

		case 0:

			vesselTracking = (VesselTrackingDTO) value$;

			break;

		case 1:

			setExceptionType(value$.toString());

			break;

		case 2:

			setArguments((Map) value$);

			break;

		case 3:

			setAggregateId(value$.toString());

			break;

		case 4:

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

			break;

		case 5:

			setType(value$.toString());

			break;

		case 6:

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

			break;

		case 7:

			setSessionId(value$.toString());

			break;

		case 8:

			setUserId(value$.toString());

			break;

		case 9:

			setId(value$.toString());

			break;

		default:

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

		}

	}



	@JsonIgnore

	public static String getVesselTrackingEventSchema() {



		return "{\"name\":\"vesselTracking\", \"type\":" + VesselTrackingDTO.SCHEMA$.toString() + "}";

	}

}

vessels-lib/src/main/java/es/redmic/vesselslib/events/vesseltracking/common/VesselTrackingEvent.java

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



import org.apache.avro.Schema;

import org.joda.time.DateTime;

import org.joda.time.DateTimeZone;



import com.fasterxml.jackson.annotation.JsonIgnore;



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

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



public abstract class VesselTrackingEvent extends Event {



	private VesselTrackingDTO vesselTracking;



	public VesselTrackingEvent(String type) {

		super(type);

	}



	public VesselTrackingDTO getVesselTracking() {

		return vesselTracking;

	}



	public void setVesselTracking(VesselTrackingDTO vesselTracking) {

		this.vesselTracking = vesselTracking;

	}



	@JsonIgnore

	@Override

	public Object get(int field$) {

		switch (field$) {

		case 0:

			return getVesselTracking();

		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");

		}

	}



	@JsonIgnore

	@Override

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

		switch (field$) {

		case 0:

			vesselTracking = (VesselTrackingDTO) value$;

			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");

		}

	}



	@JsonIgnore

	public static String getVesselTrackingEventSchema() {



		return "{\"name\":\"vesselTracking\", \"type\": " + VesselTrackingDTO.SCHEMA$.toString() + "}";

	}



	@JsonIgnore

	@Override

	public Schema getSchema() {

		return null;

	}

}