java.lang.Object
org.apache.activemq.artemis.core.server.routing.caches.LocalCache
All Implemented Interfaces:
com.github.benmanes.caffeine.cache.RemovalListener<String,String>, Cache

public class LocalCache extends Object implements Cache, com.github.benmanes.caffeine.cache.RemovalListener<String,String>
  • Constructor Details

    • LocalCache

      public LocalCache(String id, boolean persisted, int timeout, StorageManager storageManager)
  • Method Details

    • getId

      public String getId()
    • isPersisted

      public boolean isPersisted()
    • getTimeout

      public int getTimeout()
    • start

      public void start()
      Specified by:
      start in interface Cache
    • stop

      public void stop()
      Specified by:
      stop in interface Cache
    • get

      public String get(String key)
      Specified by:
      get in interface Cache
    • put

      public void put(String key, String nodeId)
      Specified by:
      put in interface Cache
    • onRemoval

      public void onRemoval(String key, String value, com.github.benmanes.caffeine.cache.RemovalCause cause)
      Specified by:
      onRemoval in interface com.github.benmanes.caffeine.cache.RemovalListener<String,String>