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=075db509f8a180910ac16bc4e4e04eaec112bfd1;hp=3297ba4939a25030667a8f5d130eb8202243e7d6;hb=46306a374d717b1579987bd678f880e6f61f72e7;hpb=ae1a275d23260149360844c30483dc89f48b13ee 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 3297ba4939..075db509f8 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 @@ -23,18 +23,18 @@ public class ConfigFeaturesListener implements FeaturesListener, AutoCloseable private BlockingQueue queue = new LinkedBlockingQueue<>(QUEUE_SIZE); Thread pushingThread = null; - public ConfigFeaturesListener(ConfigPusher p, FeaturesService f) { + public ConfigFeaturesListener(final ConfigPusher p, final FeaturesService f) { pushingThread = new Thread(new ConfigPushingRunnable(p, f, 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) { + public void repositoryEvent(final RepositoryEvent event) { LOG.debug("Repository: {} {}", event.getType(), event.getRepository()); }