X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-persister-feature-adapter%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfigpusherfeature%2Finternal%2FConfigFeaturesListener.java;h=3297ba4939a25030667a8f5d130eb8202243e7d6;hb=a110503f173ba4fbeb07a61d3c7ebf1688dfc9d6;hp=f5f1b856acac1647f00da03c194d0925e246d3e4;hpb=6faa900c307b5d97fc7726d31b6dad0e67077db8;p=controller.git diff --git a/opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigFeaturesListener.java b/opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigFeaturesListener.java index f5f1b856ac..3297ba4939 100644 --- a/opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigFeaturesListener.java +++ b/opendaylight/config/config-persister-feature-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigFeaturesListener.java @@ -9,7 +9,6 @@ package org.opendaylight.controller.configpusherfeature.internal; import java.util.concurrent.BlockingQueue; import java.util.concurrent.LinkedBlockingQueue; - import org.apache.karaf.features.FeatureEvent; import org.apache.karaf.features.FeaturesListener; import org.apache.karaf.features.FeaturesService; @@ -19,9 +18,9 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class ConfigFeaturesListener implements FeaturesListener, AutoCloseable { - private static final Logger logger = LoggerFactory.getLogger(ConfigFeaturesListener.class); - private static final int QUEUE_SIZE = 100; - private BlockingQueue queue = new LinkedBlockingQueue(QUEUE_SIZE); + private static final Logger LOG = LoggerFactory.getLogger(ConfigFeaturesListener.class); + private static final int QUEUE_SIZE = 1000; + private BlockingQueue queue = new LinkedBlockingQueue<>(QUEUE_SIZE); Thread pushingThread = null; public ConfigFeaturesListener(ConfigPusher p, FeaturesService f) { @@ -36,7 +35,7 @@ public class ConfigFeaturesListener implements FeaturesListener, AutoCloseable @Override public void repositoryEvent(RepositoryEvent event) { - logger.debug("Repository: " + event.getType() + " " + event.getRepository()); + LOG.debug("Repository: {} {}", event.getType(), event.getRepository()); } @Override