X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fcommon%2Factor%2FQuarantinedMonitorActorTest.java;h=f3a453bf4fa17db1557d21d53ca0cbe6bdb7ad7b;hp=bf5b9fca5269e3d5bb390d99d9ba585fc5507fb7;hb=a8349006607d36efd79fa58448cf8887c9fdbcf0;hpb=4b36014fa237795e4dea6dbea331b3277435e6e1 diff --git a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/common/actor/QuarantinedMonitorActorTest.java b/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/common/actor/QuarantinedMonitorActorTest.java index bf5b9fca52..f3a453bf4f 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/common/actor/QuarantinedMonitorActorTest.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/test/java/org/opendaylight/controller/cluster/common/actor/QuarantinedMonitorActorTest.java @@ -18,6 +18,7 @@ import akka.event.Logging; import akka.japi.Effect; import akka.remote.AssociationErrorEvent; import akka.remote.InvalidAssociation; +import akka.remote.ThisActorSystemQuarantinedEvent; import akka.testkit.JavaTestKit; import org.junit.After; import org.junit.Before; @@ -52,7 +53,7 @@ public class QuarantinedMonitorActorTest { public void testOnReceiveQuarantined() throws Exception { final Throwable t = new RuntimeException("Remote has quarantined this system"); final InvalidAssociation cause = InvalidAssociation.apply(LOCAL, REMOTE, t, Option.apply(null)); - final AssociationErrorEvent event = new AssociationErrorEvent(cause, LOCAL, REMOTE, true, Logging.ErrorLevel()); + final ThisActorSystemQuarantinedEvent event = new ThisActorSystemQuarantinedEvent(LOCAL, REMOTE); actor.tell(event, ActorRef.noSender()); verify(callback, timeout(1000)).apply(); }