X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-persister-feature4-adapter%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfigpusherfeature%2Finternal%2FConfigPushingRunnable.java;h=48c494b5c7d18fa188581c20b96cde855aece821;hp=cfdad560945f29cac2549274d09be37d9c704854;hb=ae1a275d23260149360844c30483dc89f48b13ee;hpb=de24c0e0c31714fb5a037d8dff72f4a285303b6a diff --git a/opendaylight/config/config-persister-feature4-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java b/opendaylight/config/config-persister-feature4-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java index cfdad56094..48c494b5c7 100644 --- a/opendaylight/config/config-persister-feature4-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java +++ b/opendaylight/config/config-persister-feature4-adapter/src/main/java/org/opendaylight/controller/configpusherfeature/internal/ConfigPushingRunnable.java @@ -25,7 +25,7 @@ public class ConfigPushingRunnable implements Runnable { private static final int POLL_TIME = 1; private BlockingQueue queue; private FeatureConfigPusher configPusher; - public ConfigPushingRunnable(ConfigPusher p, FeaturesService f,BlockingQueue q) { + public ConfigPushingRunnable(final ConfigPusher p, final FeaturesService f, final BlockingQueue q) { queue = q; configPusher = new FeatureConfigPusher(p, f); } @@ -50,16 +50,16 @@ public class ConfigPushingRunnable implements Runnable { LOG.error("ConfigPushingRunnable - exiting"); return; } - } catch (InterruptedException e) { + } catch (final InterruptedException e) { LOG.error("ConfigPushingRunnable - interupted"); interuppted = true; - } catch (Exception e) { + } catch (final Exception e) { LOG.error("Exception while processing features {} event {}", toInstall, event, e); } } } - protected void processFeatureEvent(FeatureEvent event, List toInstall) throws Exception { + protected void processFeatureEvent(final FeatureEvent event, final List toInstall) throws Exception { if(event.getType() == EventType.FeatureInstalled) { toInstall.add(event.getFeature()); LinkedHashMultimap result = configPusher.pushConfigs(toInstall); @@ -69,7 +69,7 @@ public class ConfigPushingRunnable implements Runnable { } } - protected void logPushResult(LinkedHashMultimap results) { + protected void logPushResult(final LinkedHashMultimap results) { for(Feature f:results.keySet()) { LOG.info("Pushed configs for feature {} {}",f,results.get(f)); }