Añade evento RollbackFailed + test (6d32009c) · Commits · REDMIC Project / Server / Library / Broker lib

src/main/java/es/redmic/brokerlib/avro/fail/RollbackFailedEvent.java

0 → 100644

+112 −0

Original line number	Diff line number	Diff line
		package es.redmic.brokerlib.avro.fail;

		/*-
		* #%L
		* broker-lib
		* %%
		* Copyright (C) 2019 REDMIC Project / Server
		* %%
		* Licensed under the Apache License, Version 2.0 (the "License");
		* you may not use this file except in compliance with the License.
		* You may obtain a copy of the License at
		*
		* http://www.apache.org/licenses/LICENSE-2.0
		*
		* Unless required by applicable law or agreed to in writing, software
		* distributed under the License is distributed on an "AS IS" BASIS,
		* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
		* See the License for the specific language governing permissions and
		* limitations under the License.
		* #L%
		*/

		import org.apache.avro.Schema;
		import org.joda.time.DateTime;
		import org.joda.time.DateTimeZone;

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

		public class RollbackFailedEvent extends BaseRollbackEvent {

		// @formatter:off

		public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{"
		+ "\"type\":\"record\",\"name\":\"RollbackFailedEvent\","
		+ "\"namespace\":\"es.redmic.brokerlib.avro.fail\",\"fields\":["
		+ "{\"name\":\"failEventType\",\"type\": \"string\"},"
		+ getEventBaseSchema() + "]}");

		// @formatter:on

		static String type = EventTypes.ROLLBACK_FAILED;

		public RollbackFailedEvent() {
		super(type);
		}

		public RollbackFailedEvent(String failEventType) {
		super(type);
		this.setFailEventType(failEventType);
		}

		@Override
		public Object get(int field$) {
		switch (field$) {
		case 0:
		return getFailEventType();
		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");
		}
		}

		@Override
		public void put(int field$, Object value$) {
		switch (field$) {
		case 0:
		setFailEventType(value$.toString());
		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");
		}
		}

		@Override
		public Schema getSchema() {
		return SCHEMA$;
		}
		}

src/test/java/es/redmic/brokerlib/avro/FailEventsCheckAvroSchemaTest.java

+18 −0

Original line number	Diff line number	Diff line
		@@ -28,6 +28,7 @@ import java.util.UUID;
		import org.junit.Test;

		import es.redmic.brokerlib.avro.fail.PrepareRollbackEvent;
		import es.redmic.brokerlib.avro.fail.RollbackFailedEvent;
		import es.redmic.brokerlib.utils.AvroBaseTest;

		public class FailEventsCheckAvroSchemaTest extends AvroBaseTest {
		@@ -49,4 +50,21 @@ public class FailEventsCheckAvroSchemaTest extends AvroBaseTest {

		assertEquals(result, event);
		}

		@Test
		public void RollbackFailedEventSerializeAndDeserialize_IsSuccessful_IfSchemaAndDataAreCorrect() {

		RollbackFailedEvent event = new RollbackFailedEvent("failEventType");
		event.setAggregateId("aggregateId");
		event.setSessionId(UUID.randomUUID().toString());
		event.setUserId("userId");
		event.setVersion(1);

		Object result = serializerAndDeserializer(event);

		assertTrue("El objeto obtenido debe ser una instancia de RollbackFailedEvent",
		RollbackFailedEvent.class.isInstance(result));

		assertEquals(result, event);
		}
		}