opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DatastoreContextPropertiesUpdater.java

   1 /*
   2  * Copyright (c) 2017 Pantheon Technologies, s.r.o. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.controller.cluster.datastore;
   9
  10 import java.util.Map;
  11 import org.slf4j.Logger;
  12 import org.slf4j.LoggerFactory;
  13
  14 /**
  15  * Update DatastoreContext settings on invoke update method.
  16  *
  17  */
  18 public class DatastoreContextPropertiesUpdater implements AutoCloseable {
  19
  20     public interface Listener {
  21         void onDatastoreContextUpdated(DatastoreContextFactory contextFactory);
  22     }
  23
  24     private static final Logger LOG = LoggerFactory.getLogger(DatastoreContextPropertiesUpdater.class);
  25
  26     private final DatastoreContextIntrospector introspector;
  27     private Listener listener;
  28
  29     /**
  30      * Base init of updater for DatastoreContext settings with base properties.
  31      *
  32      * @param introspector
  33      *            - introspection on DatastoreContext
  34      * @param props
  35      *            - base properties
  36      */
  37     public DatastoreContextPropertiesUpdater(final DatastoreContextIntrospector introspector,
  38             final Map<String, Object> props) {
  39         this.introspector = introspector;
  40         update(props);
  41     }
  42
  43     public void setListener(final Listener listener) {
  44         this.listener = listener;
  45     }
  46
  47     public void update(final Map<String, Object> properties) {
  48         LOG.debug("Overlaying settings: {}", properties);
  49
  50         if (introspector.update(properties) && listener != null) {
  51             listener.onDatastoreContextUpdated(introspector.newContextFactory());
  52         }
  53     }
  54
  55     @Override
  56     public void close() {
  57         listener = null;
  58     }
  59 }