https://bugs.opendaylight.org/show_bug.cgi?id=7538 has full background
Bug: 7538
Change-Id: Ic3f2169e18928e3010e45bddb43186cc53d897f4
Signed-off-by: Michael Vorburger <vorburger@redhat.com>
import com.google.common.collect.ImmutableMap;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
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;
import javassist.ClassPool;
import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
return new BindingDOMNotificationPublishServiceAdapter(bindingToNormalized, domNotificationRouter);
}
return new BindingDOMNotificationPublishServiceAdapter(bindingToNormalized, domNotificationRouter);
}
public ListeningExecutorService getCommitCoordinatorExecutor() {
public ListeningExecutorService getCommitCoordinatorExecutor() {
- return MoreExecutors.newDirectExecutorService();
+ return MoreExecutors.listeningDecorator(Executors.newSingleThreadExecutor());
}
public DataBroker createDataBroker() {
}
public DataBroker createDataBroker() {
}
private DOMDataBroker getDOMDataBroker() {
}
private DOMDataBroker getDOMDataBroker() {
- if(domDataBroker == null) {
+ if (domDataBroker == null) {
domDataBroker = createDOMDataBroker();
}
return domDataBroker;
domDataBroker = createDOMDataBroker();
}
return domDataBroker;