Class AbstractJCacheNotifier<K,​V>

  • All Implemented Interfaces:
    Closeable, AutoCloseable

    public abstract class AbstractJCacheNotifier<K,​V>
    extends Object
    implements Closeable
    JCache notifications dispatcher. TODO: Deal with asynchronous listeners...
    Since:
    5.3
    Author:
    Galder ZamarreƱo
    • Constructor Detail

      • AbstractJCacheNotifier

        public AbstractJCacheNotifier()
    • Method Detail

      • removeListener

        public void removeListener​(javax.cache.configuration.CacheEntryListenerConfiguration<K,​V> reg,
                                   AbstractJCache<K,​V> jcache)
      • addSyncNotificationLatch

        public void addSyncNotificationLatch​(javax.cache.Cache<K,​V> cache,
                                             K key,
                                             V value,
                                             CountDownLatch latch)
      • removeSyncNotificationLatch

        public void removeSyncNotificationLatch​(javax.cache.Cache<K,​V> cache,
                                                K key,
                                                V value,
                                                CountDownLatch latch)
      • notifyEntryCreated

        public void notifyEntryCreated​(javax.cache.Cache<K,​V> cache,
                                       K key,
                                       V value)
      • notifyEntryUpdated

        public void notifyEntryUpdated​(javax.cache.Cache<K,​V> cache,
                                       K key,
                                       V value,
                                       V prev)
      • notifyEntryRemoved

        public void notifyEntryRemoved​(javax.cache.Cache<K,​V> cache,
                                       K key,
                                       V value,
                                       V prev)
      • notifyEntryExpired

        public void notifyEntryExpired​(javax.cache.Cache<K,​V> cache,
                                       K key,
                                       V value)
      • hasSyncCreatedListener

        public boolean hasSyncCreatedListener()
      • hasSyncRemovedListener

        public boolean hasSyncRemovedListener()
      • hasSyncUpdatedListener

        public boolean hasSyncUpdatedListener()
      • createFilterIfNeeded

        protected javax.cache.event.CacheEntryEventFilter<? super K,​? super V> createFilterIfNeeded​(javax.cache.configuration.CacheEntryListenerConfiguration<K,​V> listenerCfg)