X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-manager%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fmanager%2Fimpl%2Fosgi%2FExtensibleBundleTracker.java;h=61c050506e4130e0937b898ea26003e721ce40ef;hp=eff267ad1319c90c1ce9e06de2ff7bcaddc86c67;hb=493c4f70a0a315d77927e4c0d90a90acbbcb2897;hpb=17d82f582a6bc13c78be3b19954ff8c021180e93 diff --git a/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/ExtensibleBundleTracker.java b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/ExtensibleBundleTracker.java index eff267ad13..61c050506e 100644 --- a/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/ExtensibleBundleTracker.java +++ b/opendaylight/config/config-manager/src/main/java/org/opendaylight/controller/config/manager/impl/osgi/ExtensibleBundleTracker.java @@ -7,13 +7,11 @@ */ package org.opendaylight.controller.config.manager.impl.osgi; -import com.google.common.util.concurrent.ThreadFactoryBuilder; +import com.google.common.util.concurrent.MoreExecutors; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; import java.util.concurrent.Future; -import java.util.concurrent.ThreadFactory; import org.osgi.framework.Bundle; import org.osgi.framework.BundleContext; import org.osgi.framework.BundleEvent; @@ -50,9 +48,6 @@ import org.slf4j.LoggerFactory; */ public final class ExtensibleBundleTracker extends BundleTracker> { - private static final ThreadFactory THREAD_FACTORY = new ThreadFactoryBuilder() - .setNameFormat("config-bundle-tracker-%d") - .build(); private final ExecutorService eventExecutor; private final BundleTrackerCustomizer primaryTracker; private final BundleTrackerCustomizer[] additionalTrackers; @@ -70,7 +65,7 @@ public final class ExtensibleBundleTracker extends BundleTracker> { super(context, bundleState, null); this.primaryTracker = primaryBundleTrackerCustomizer; this.additionalTrackers = additionalBundleTrackerCustomizers; - eventExecutor = Executors.newSingleThreadExecutor(THREAD_FACTORY); + eventExecutor = MoreExecutors.newDirectExecutorService(); LOG.trace("Registered as extender with context {} and bundle state {}", context, bundleState); } @@ -92,7 +87,7 @@ public final class ExtensibleBundleTracker extends BundleTracker> { LOG.trace("AddingBundle for {} and event {} finished successfully",bundle,event); return primaryTrackerRetVal; } catch (Exception e) { - LOG.error("Failed to add bundle {}",e); + LOG.error("Failed to add bundle ",e); throw e; } }