X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netconf%2Fnetconf-topology-singleton%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fnetconf%2Ftopology%2Fsingleton%2Fimpl%2Ftx%2FProxyReadWriteTransactionTest.java;h=8cbfb26268c576d9f42bb423df6d34211b033d9c;hb=4f8fe6ca68115fecdb9ce43573af5a2e26c50b50;hp=591b57067aa7e9724ea0f4807410f0dfa2b23ab2;hpb=69b321b4b4180b4f7f03f30590ce36c78365b04f;p=netconf.git diff --git a/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/tx/ProxyReadWriteTransactionTest.java b/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/tx/ProxyReadWriteTransactionTest.java index 591b57067a..8cbfb26268 100644 --- a/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/tx/ProxyReadWriteTransactionTest.java +++ b/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/tx/ProxyReadWriteTransactionTest.java @@ -203,13 +203,13 @@ public class ProxyReadWriteTransactionTest { public void testRead() throws Exception { ProxyReadWriteTransaction tx = newSuccessfulProxyTx(); - final ListenableFuture>> read = tx.read(STORE, PATH); + final ListenableFuture> read = tx.read(STORE, PATH); final ReadRequest readRequest = masterActor.expectMsgClass(ReadRequest.class); assertEquals(STORE, readRequest.getStore()); assertEquals(PATH, readRequest.getPath()); masterActor.reply(new NormalizedNodeMessage(PATH, node)); - final Optional> result = read.get(5, TimeUnit.SECONDS); + final Optional result = read.get(5, TimeUnit.SECONDS); assertTrue(result.isPresent()); assertEquals(node, result.get()); } @@ -218,10 +218,10 @@ public class ProxyReadWriteTransactionTest { public void testReadEmpty() throws Exception { ProxyReadWriteTransaction tx = newSuccessfulProxyTx(); - final ListenableFuture>> read = tx.read(STORE, PATH); + final ListenableFuture> read = tx.read(STORE, PATH); masterActor.expectMsgClass(ReadRequest.class); masterActor.reply(new EmptyReadResponse()); - final Optional> result = read.get(5, TimeUnit.SECONDS); + final Optional result = read.get(5, TimeUnit.SECONDS); assertFalse(result.isPresent()); } @@ -229,7 +229,7 @@ public class ProxyReadWriteTransactionTest { public void testReadFailure() throws InterruptedException, TimeoutException { ProxyReadWriteTransaction tx = newSuccessfulProxyTx(); - final ListenableFuture>> read = tx.read(STORE, PATH); + final ListenableFuture> read = tx.read(STORE, PATH); masterActor.expectMsgClass(ReadRequest.class); final RuntimeException mockEx = new RuntimeException("fail"); masterActor.reply(new Failure(mockEx)); @@ -327,7 +327,7 @@ public class ProxyReadWriteTransactionTest { ProxyReadWriteTransaction tx = new ProxyReadWriteTransaction(DEVICE_ID, promise.future(), system.dispatcher(), Timeout.apply(5, TimeUnit.SECONDS)); - final ListenableFuture>> read = tx.read(STORE, PATH); + final ListenableFuture> read = tx.read(STORE, PATH); final ListenableFuture exists = tx.exists(STORE, PATH); tx.put(STORE, PATH, node);