private BlockingQueue<FeatureEvent> 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());
}