Tune eos gossip/notification intervals

[controller.git] / opendaylight / md-sal / eos-dom-akka / src / test / java / org / opendaylight / controller / eos / akka / SingleNodeTest.java

diff --git a/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/SingleNodeTest.java b/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/SingleNodeTest.java
index 9b8862bbae2117d33fc243052e38e89edc8f4af4..e4971785f30879e970d1ebb11eafc7529d25f7b1 100644 (file)
--- a/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/SingleNodeTest.java
+++ b/opendaylight/md-sal/eos-dom-akka/src/test/java/org/opendaylight/controller/eos/akka/SingleNodeTest.java
@@ -8,6 +8,7 @@
 package org.opendaylight.controller.eos.akka;
 
 import akka.actor.testkit.typed.javadsl.ActorTestKit;
+import java.time.Duration;
 import java.util.List;
 import org.junit.After;
 import org.junit.Before;
@@ -28,7 +29,7 @@ public class SingleNodeTest extends AbstractNativeEosTest {
 
     @After
     public void tearDown() {
-        ActorTestKit.shutdown(clusterNode.getActorSystem());
+        ActorTestKit.shutdown(clusterNode.getActorSystem(), Duration.ofSeconds(20));
     }
 
     @Test
@@ -52,6 +53,7 @@ public class SingleNodeTest extends AbstractNativeEosTest {
 
         registerCandidates(clusterNode, ENTITY_1, "member-2", "member-3");
         verifyListenerState(listener, ENTITY_1, true, true, false);
+        verifyNoAdditionalNotifications(listener, 5);
 
         unregisterCandidates(clusterNode, ENTITY_1, "member-1");
         verifyListenerState(listener, ENTITY_1, true, false, true);
@@ -67,6 +69,7 @@ public class SingleNodeTest extends AbstractNativeEosTest {
 
         final MockEntityOwnershipListener listener = registerListener(clusterNode, ENTITY_1);
         verifyListenerState(listener, ENTITY_1, true, true, false);
+        verifyNoAdditionalNotifications(listener, 5);
 
         unregisterCandidates(clusterNode, ENTITY_1, "member-1", "member-2");
         verifyListenerState(listener, ENTITY_1, true, false, true);