X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-binding-broker%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fyang%2Fmd%2Fsal%2Fbinding%2Fimpl%2FNotificationBrokerImplModule.java;h=415c9783da4891bf151afed1eb4b946a0531f1cb;hb=ee04fdfc14f438a7fa6b1cd63e8756386293f6c8;hp=b6c27a6332c4fdc7ddc6c08e25970f51431c8260;hpb=2e7347fdc0eb7734ff59a4f902227a93ab6afece;p=controller.git diff --git a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/NotificationBrokerImplModule.java b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/NotificationBrokerImplModule.java index b6c27a6332..415c9783da 100644 --- a/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/NotificationBrokerImplModule.java +++ b/opendaylight/md-sal/sal-binding-broker/src/main/java/org/opendaylight/controller/config/yang/md/sal/binding/impl/NotificationBrokerImplModule.java @@ -7,11 +7,10 @@ */ package org.opendaylight.controller.config.yang.md.sal.binding.impl; +import com.google.common.util.concurrent.ListeningExecutorService; import org.opendaylight.controller.sal.binding.codegen.impl.SingletonHolder; import org.opendaylight.controller.sal.binding.impl.NotificationBrokerImpl; -import com.google.common.util.concurrent.ListeningExecutorService; - /** * */ @@ -37,6 +36,13 @@ public final class NotificationBrokerImplModule extends @Override public java.lang.AutoCloseable createInstance() { + + /* + * FIXME: Switch to new broker (which has different threading model) + * once this change is communicated with downstream users or + * we will have adapter implementation which will honor Helium + * threading model for notifications. + */ ListeningExecutorService listeningExecutor = SingletonHolder.getDefaultNotificationExecutor(); NotificationBrokerImpl broker = new NotificationBrokerImpl(listeningExecutor); return broker;