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

Hace uso de isSnapshot de la util

parent df6def47

vessels-commands/src/main/java/es/redmic/vesselscommands/streams/VesselTypeEventStreams.java

+2 −8
Original line number Diff line number Diff line
@@ -144,7 +144,7 @@ public class VesselTypeEventStreams extends EventSourcingStreams { 


		assert failedEvent.getType().equals(VesselTypeEventTypes.UPDATE_FAILED);



		assert isSnapshot(lastSuccessEvent.getType());

		assert VesselTypeEventTypes.isSnapshot(lastSuccessEvent.getType());



		VesselTypeDTO vesselType = ((VesselTypeEvent) lastSuccessEvent).getVesselType();
@@ -164,7 +164,7 @@ public class VesselTypeEventStreams extends EventSourcingStreams { 


		assert failedEvent.getType().equals(VesselTypeEventTypes.DELETE_FAILED);



		assert isSnapshot(lastSuccessEvent.getType());

		assert VesselTypeEventTypes.isSnapshot(lastSuccessEvent.getType());



		VesselTypeDTO vesselType = ((VesselTypeEvent) lastSuccessEvent).getVesselType();
@@ -174,12 +174,6 @@ public class VesselTypeEventStreams extends EventSourcingStreams { 
				eventError.getExceptionType(), eventError.getArguments());

	}



	@Override

	protected boolean isSnapshot(String eventType) {



		return VesselTypeEventTypes.isSnapshot(eventType);

	}



	@Override

	protected void processEnrichCreateSteam(KStream<String, Event> events) {

		// En este caso no hay enriquecimiento