java.lang.Object
org.apache.curator.framework.recipes.cache.NodeCache
All Implemented Interfaces:
Closeable, AutoCloseable

@Deprecated public class NodeCache extends Object implements Closeable
Deprecated.
replace by CuratorCache

A utility that attempts to keep the data from a node locally cached. This class will watch the node, respond to update/create/delete events, pull down the data, etc. You can register a listener that will get notified when changes occur.

IMPORTANT - it's not possible to stay transactionally in sync. Users of this class must be prepared for false-positives and false-negatives. Additionally, always use the version number when updating data to avoid overwriting another process' change.

  • Constructor Details

    • NodeCache

      public NodeCache(CuratorFramework client, String path)
      Deprecated.
      Parameters:
      client - curator client
      path - the full path to the node to cache
    • NodeCache

      public NodeCache(CuratorFramework client, String path, boolean dataIsCompressed)
      Deprecated.
      Parameters:
      client - curator client
      path - the full path to the node to cache
      dataIsCompressed - if true, data in the path is compressed
  • Method Details

    • getClient

      public CuratorFramework getClient()
      Deprecated.
    • start

      public void start() throws Exception
      Deprecated.
      Start the cache. The cache is not started automatically. You must call this method.
      Throws:
      Exception - errors
    • start

      public void start(boolean buildInitial) throws Exception
      Deprecated.
      Same as start() but gives the option of doing an initial build
      Parameters:
      buildInitial - if true, rebuild() will be called before this method returns in order to get an initial view of the node
      Throws:
      Exception - errors
    • close

      public void close() throws IOException
      Deprecated.
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException
    • getListenable

      public Listenable<NodeCacheListener> getListenable()
      Deprecated.
      Return the cache listenable
      Returns:
      listenable
    • rebuild

      public void rebuild() throws Exception
      Deprecated.
      NOTE: this is a BLOCKING method. Completely rebuild the internal cache by querying for all needed data WITHOUT generating any events to send to listeners.
      Throws:
      Exception - errors
    • getCurrentData

      public ChildData getCurrentData()
      Deprecated.
      Return the current data. There are no guarantees of accuracy. This is merely the most recent view of the data. If the node does not exist, this returns null
      Returns:
      data or null
    • getPath

      public String getPath()
      Deprecated.
      Return the path this cache is watching
      Returns:
      path
    • handleException

      protected void handleException(Throwable e)
      Deprecated.
      Default behavior is just to log the exception
      Parameters:
      e - the exception