X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fmd%2Fsal%2Fbinding%2Ftest%2FDataBrokerTestCustomizer.java;h=8d34cbd2cd6f7b5df33b2008e9bb806e0780f9fb;hp=23600a3710cc7207c9d20c095e13a067b27c265a;hb=930817d4f1e01c7e08fd7e8ad79bf781cb53034a;hpb=9df6b6451e5d77cbadb030859b3004e3383287a1;ds=sidebyside diff --git a/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java b/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java index 23600a3710..8d34cbd2cd 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java +++ b/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/DataBrokerTestCustomizer.java @@ -10,6 +10,7 @@ package org.opendaylight.controller.md.sal.binding.test; import com.google.common.collect.ImmutableMap; import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; +import java.util.concurrent.Executors; import javassist.ClassPool; import org.opendaylight.controller.md.sal.binding.api.DataBroker; import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService; @@ -83,9 +84,8 @@ public class DataBrokerTestCustomizer { return new BindingDOMNotificationPublishServiceAdapter(bindingToNormalized, domNotificationRouter); } - public ListeningExecutorService getCommitCoordinatorExecutor() { - return MoreExecutors.newDirectExecutorService(); + return MoreExecutors.listeningDecorator(Executors.newSingleThreadExecutor()); } public DataBroker createDataBroker() { @@ -101,7 +101,7 @@ public class DataBrokerTestCustomizer { } private DOMDataBroker getDOMDataBroker() { - if(domDataBroker == null) { + if (domDataBroker == null) { domDataBroker = createDOMDataBroker(); } return domDataBroker;