X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-persister-feature-adapter%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfigpusherfeature%2Finternal%2FConfigFeaturesListener.java;h=d5d590aadcde6524954334c8f0818d6533ad6c10;hp=b8f18960d109f60d5d33e3683035784387ee0a86;hb=f43b01b81319959b1907e3e04537f5169e7f33d8;hpb=6e3f5765d348492f7977228969cd7987e44697cb

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 b8f18960d1..d5d590aadc 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
@@ -18,30 +18,31 @@ import org.opendaylight.controller.config.persist.api.ConfigPusher;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class ConfigFeaturesListener implements  FeaturesListener,  AutoCloseable {
-    private static final Logger logger = LoggerFactory.getLogger(ConfigFeaturesListener.class);
+public class ConfigFeaturesListener implements FeaturesListener, AutoCloseable {
+    private static final Logger LOG = LoggerFactory.getLogger(ConfigFeaturesListener.class);
     private static final int QUEUE_SIZE = 1000;
-    private BlockingQueue<FeatureEvent> queue = new LinkedBlockingQueue<FeatureEvent>(QUEUE_SIZE);
+    private BlockingQueue<FeatureEvent> queue = new LinkedBlockingQueue<>(QUEUE_SIZE);
     Thread pushingThread = null;
 
-    public ConfigFeaturesListener(ConfigPusher p, FeaturesService f) {
-        pushingThread = new Thread(new ConfigPushingRunnable(p, f, queue), "ConfigFeatureListener - ConfigPusher");
+    public ConfigFeaturesListener(final ConfigPusher configPusher, final FeaturesService featuresService) {
+        pushingThread = new Thread(new ConfigPushingRunnable(configPusher, featuresService, queue),
+                "ConfigFeatureListener - ConfigPusher");
         pushingThread.start();
     }
 
     @Override
-    public void featureEvent(FeatureEvent event) {
+    public void featureEvent(final FeatureEvent event) {
         queue.offer(event);
     }
 
     @Override
-    public void repositoryEvent(RepositoryEvent event) {
-        logger.debug("Repository: " + event.getType() + " " + event.getRepository());
+    public void repositoryEvent(final RepositoryEvent event) {
+        LOG.debug("Repository: {} {}", event.getType(), event.getRepository());
     }
 
     @Override
     public void close() {
-        if(pushingThread != null) {
+        if (pushingThread != null) {
             pushingThread.interrupt();
             pushingThread = null;
         }