X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDataTreeChangeListenerProxyTest.java;h=c66c3cd0aeb264291fad8aeddb3e3da7b68f1aad;hb=refs%2Fchanges%2F85%2F57185%2F2;hp=927f9297979453589d2e2fa59c96ce82910df3c1;hpb=e4550bea5b9d5589b1937d5a4496abde2f476b2e;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeChangeListenerProxyTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeChangeListenerProxyTest.java index 927f929797..c66c3cd0ae 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeChangeListenerProxyTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DataTreeChangeListenerProxyTest.java @@ -60,13 +60,7 @@ public class DataTreeChangeListenerProxyTest extends AbstractActorTest { final DataTreeChangeListenerProxy proxy = new DataTreeChangeListenerProxy<>( actorContext, mockListener, path); - new Thread() { - @Override - public void run() { - proxy.init("shard-1"); - } - - }.start(); + new Thread(() -> proxy.init("shard-1")).start(); FiniteDuration timeout = duration("5 seconds"); FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class); @@ -119,13 +113,7 @@ public class DataTreeChangeListenerProxyTest extends AbstractActorTest { final DataTreeChangeListenerProxy proxy = new DataTreeChangeListenerProxy<>(actorContext, mockClusteredListener, path); - new Thread() { - @Override - public void run() { - proxy.init("shard-1"); - } - - }.start(); + new Thread(() -> proxy.init("shard-1")).start(); FiniteDuration timeout = duration("5 seconds"); FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class); @@ -154,13 +142,7 @@ public class DataTreeChangeListenerProxyTest extends AbstractActorTest { final DataTreeChangeListenerProxy proxy = new DataTreeChangeListenerProxy<>( actorContext, mockListener, path); - new Thread() { - @Override - public void run() { - proxy.init("shard-1"); - } - - }.start(); + new Thread(() -> proxy.init("shard-1")).start(); FiniteDuration timeout = duration("5 seconds"); FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class); @@ -186,13 +168,7 @@ public class DataTreeChangeListenerProxyTest extends AbstractActorTest { final DataTreeChangeListenerProxy proxy = new DataTreeChangeListenerProxy<>( actorContext, mockListener, path); - new Thread() { - @Override - public void run() { - proxy.init("shard-1"); - } - - }.start(); + new Thread(() -> proxy.init("shard-1")).start(); FiniteDuration timeout = duration("5 seconds"); FindLocalShard findLocalShard = expectMsgClass(timeout, FindLocalShard.class);