Bug 8152: Transaction is already opened

[netconf.git] / netconf / netconf-topology-singleton / src / test / java / org / opendaylight / netconf / topology / singleton / impl / actors / WriteTransactionActorTest.java

diff --git a/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/actors/WriteTransactionActorTest.java b/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/actors/WriteTransactionActorTest.java
index d95d15840b5d7ece72fffcc5353911749e1a431e..158ee468ba2ef37bd4236d3e8b60e653865c1ab8 100644 (file)
--- a/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/actors/WriteTransactionActorTest.java
+++ b/netconf/netconf-topology-singleton/src/test/java/org/opendaylight/netconf/topology/singleton/impl/actors/WriteTransactionActorTest.java
@@ -8,6 +8,7 @@
 
 package org.opendaylight.netconf.topology.singleton.impl.actors;
 
+import static org.mockito.Mockito.timeout;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 
@@ -44,6 +45,7 @@ import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
 import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
 import scala.concurrent.Await;
 import scala.concurrent.Future;
+import scala.concurrent.duration.Duration;
 
 public class WriteTransactionActorTest {
     private static final YangInstanceIdentifier PATH = YangInstanceIdentifier.EMPTY;
@@ -65,7 +67,8 @@ public class WriteTransactionActorTest {
         node = Builders.containerBuilder()
                 .withNodeIdentifier(new YangInstanceIdentifier.NodeIdentifier(QName.create("cont")))
                 .build();
-        actorRef = TestActorRef.create(system, WriteTransactionActor.props(deviceWriteTx), "testA");
+        actorRef = TestActorRef.create(system, WriteTransactionActor.props(deviceWriteTx,
+                Duration.apply(2, TimeUnit.SECONDS)), "testA");
     }
 
     @After
@@ -124,4 +127,12 @@ public class WriteTransactionActorTest {
         verify(deviceWriteTx).submit();
     }
 
+    @Test
+    public void testIdleTimeout() throws Exception {
+        final TestProbe probe = new TestProbe(system);
+        probe.watch(actorRef);
+        verify(deviceWriteTx, timeout(3000)).cancel();
+        probe.expectTerminated(actorRef, TIMEOUT.duration());
+    }
+
 }
\ No newline at end of file