import org.junit.Assert;
import org.junit.Test;
-import org.opendaylight.controller.cluster.access.ABIVersion;
+import org.opendaylight.controller.cluster.access.concepts.AbstractRequestTest;
+import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
+import org.opendaylight.controller.cluster.access.concepts.FrontendIdentifier;
+import org.opendaylight.controller.cluster.access.concepts.FrontendType;
+import org.opendaylight.controller.cluster.access.concepts.LocalHistoryIdentifier;
+import org.opendaylight.controller.cluster.access.concepts.MemberName;
+import org.opendaylight.controller.cluster.access.concepts.RequestException;
+import org.opendaylight.controller.cluster.access.concepts.RuntimeRequestException;
+import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
-public abstract class AbstractTransactionRequestTest<T extends AbstractLocalTransactionRequest> {
- abstract T object();
+public abstract class AbstractTransactionRequestTest<T extends TransactionRequest<T>>
+ extends AbstractRequestTest<T> {
+ private static final FrontendIdentifier FRONTEND_IDENTIFIER = FrontendIdentifier.create(
+ MemberName.forName("test"), FrontendType.forName("one"));
+ private static final ClientIdentifier CLIENT_IDENTIFIER = ClientIdentifier.create(FRONTEND_IDENTIFIER, 0);
+ private static final LocalHistoryIdentifier HISTORY_IDENTIFIER = new LocalHistoryIdentifier(
+ CLIENT_IDENTIFIER, 0);
+ protected static final TransactionIdentifier TRANSACTION_IDENTIFIER = new TransactionIdentifier(
+ HISTORY_IDENTIFIER, 0);
- @Test(expected = UnsupportedOperationException.class)
- public void testExternalizableProxy() {
- object().externalizableProxy(ABIVersion.BORON);
- }
+ @Override
+ protected abstract T object();
@Test
- public void cloneAsVersionTest() {
- Assert.assertEquals(object(), object().cloneAsVersion(ABIVersion.BORON));
+ public void toRequestFailureTest() {
+ final Throwable cause = new Throwable();
+ final RequestException exception = new RuntimeRequestException("fail", cause);
+ final TransactionFailure failure = object().toRequestFailure(exception);
+ Assert.assertNotNull(failure);
}
}