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%2FAbstractDataBrokerTestCustomizer.java;h=375a9f119c3787adaec7e8b3f36f704d72ce19f7;hp=8d968b0a01526da6cbd6892f20d775e57f5cec31;hb=refs%2Fchanges%2F12%2F60312%2F1;hpb=1e50fbad8d8605b73d5b2be8f5ae30b437b33780 diff --git a/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/AbstractDataBrokerTestCustomizer.java b/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/AbstractDataBrokerTestCustomizer.java index 8d968b0a01..375a9f119c 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/AbstractDataBrokerTestCustomizer.java +++ b/opendaylight/md-sal/sal-binding-broker/src/test/java/org/opendaylight/controller/md/sal/binding/test/AbstractDataBrokerTestCustomizer.java @@ -40,7 +40,6 @@ public abstract class AbstractDataBrokerTestCustomizer { private final MockSchemaService schemaService; private ImmutableMap datastores; private final BindingToNormalizedNodeCodec bindingToNormalized; - private ListeningExecutorService dataTreeChangeListenerExecutor = MoreExecutors.newDirectExecutorService(); public ImmutableMap createDatastores() { return ImmutableMap.builder() @@ -61,13 +60,13 @@ public abstract class AbstractDataBrokerTestCustomizer { } public DOMStore createConfigurationDatastore() { - final InMemoryDOMDataStore store = new InMemoryDOMDataStore("CFG", dataTreeChangeListenerExecutor); + final InMemoryDOMDataStore store = new InMemoryDOMDataStore("CFG", getDataTreeChangeListenerExecutor()); this.schemaService.registerSchemaContextListener(store); return store; } public DOMStore createOperationalDatastore() { - final InMemoryDOMDataStore store = new InMemoryDOMDataStore("OPER", dataTreeChangeListenerExecutor); + final InMemoryDOMDataStore store = new InMemoryDOMDataStore("OPER", getDataTreeChangeListenerExecutor()); this.schemaService.registerSchemaContextListener(store); return store; } @@ -86,6 +85,10 @@ public abstract class AbstractDataBrokerTestCustomizer { public abstract ListeningExecutorService getCommitCoordinatorExecutor(); + public ListeningExecutorService getDataTreeChangeListenerExecutor() { + return MoreExecutors.newDirectExecutorService(); + } + public DataBroker createDataBroker() { return new BindingDOMDataBrokerAdapter(getDOMDataBroker(), this.bindingToNormalized); } @@ -112,10 +115,6 @@ public abstract class AbstractDataBrokerTestCustomizer { return this.datastores; } - public void setDataTreeChangeListenerExecutor(ListeningExecutorService executor) { - this.dataTreeChangeListenerExecutor = executor; - } - public void updateSchema(final SchemaContext ctx) { this.schemaService.changeSchema(ctx); }