Commit 4a9adf9f authored by Noel Alonso's avatar Noel Alonso
Browse files

Añade método para obtener evento fail por acción 

De este modo se puede enviar el evento fail que corresponde con el
evento bloqueado
parent 92150849

src/main/java/es/redmic/brokerlib/avro/common/EventTypes.java

+21 −1
Original line number Diff line number Diff line 
package es.redmic.brokerlib.avro.common;



import java.util.Arrays;



/*-

 * #%L

 * broker-lib
@@ -53,7 +55,8 @@ public abstract class EventTypes { 
		DELETE_CANCELLED = "DELETE_CANCELLED",

		//FAIL

		PREPARE_ROLLBACK = "PREPARE_ROLLBACK",

		ROLLBACK = "ROLLBACK";

		ROLLBACK = "ROLLBACK",

		ROLLBACK_FAILED = "ROLLBACK_FAILED";

		//@formatter:on



	/**
@@ -97,4 +100,21 @@ public abstract class EventTypes { 


		return (isSnapshot(eventType) && !eventType.equals(EventTypes.DELETED.toString()));

	}



	public static String getEventFailedTypeByActionType(String actionType) {



		if (Arrays.asList(CREATE, ENRICH_CREATE, CREATE_ENRICHED, CREATE_ENRICH_FAILED, CREATE_CONFIRMED, CREATE_FAILED)

				.contains(actionType)) {

			return CREATE_FAILED;

		}

		if (Arrays.asList(UPDATE, ENRICH_UPDATE, UPDATE_ENRICHED, UPDATE_ENRICH_FAILED, UPDATE_CONFIRMED, UPDATE_FAILED)

				.contains(actionType)) {

			return UPDATE_FAILED;

		}

		if (Arrays.asList(DELETE, CHECK_DELETE, DELETE_CHECKED, DELETE_CHECK_FAILED, DELETE_CONFIRMED, DELETE_FAILED)

				.contains(actionType)) {

			return DELETE_FAILED;

		}

		return null;

	}

}