org.codice.ddf.catalog.subscriptionstore

Class SubscriptionCacheLoader

java.lang.Object

org.codice.ddf.catalog.subscriptionstore.SubscriptionCacheLoader

All Implemented Interfaces:

javax.cache.integration.CacheLoader<String,CachedSubscription>

public class SubscriptionCacheLoader
extends Object
implements javax.cache.integration.CacheLoader<String,CachedSubscription>

CacheLoader implementation for the Cache in SubscriptionContainerImpl. All inner exceptions will be handled by the cache implementation, or rethrown as a CacheException.

Constructor Summary

Constructors

Constructor and Description
SubscriptionCacheLoader(SubscriptionPersistor persistor)

Method Summary

Modifier and Type	Method and Description
CachedSubscription	load(String key)
Map<String,CachedSubscription>	loadAll(Iterable<? extends String> keys) Implementation detail.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubscriptionCacheLoader

public SubscriptionCacheLoader(SubscriptionPersistor persistor)

Method Detail

load

public CachedSubscription load(String key)
                        throws javax.cache.integration.CacheLoaderException

Specified by:

load in interface javax.cache.integration.CacheLoader<String,CachedSubscription>

Throws:

javax.cache.integration.CacheLoaderException

loadAll

public Map<String,CachedSubscription> loadAll(Iterable<? extends String> keys)
                                       throws javax.cache.integration.CacheLoaderException

Implementation detail. We need to ignore the keys because we don't know them at load time. If we want to honor the keys, and know them at load time, we will need to ping the persistent store twice. But there's no point to doing that (for the sake of an API). The keys don't matter - we're loading everything that we can load regardless of the keys provided.

Specified by:

loadAll in interface javax.cache.integration.CacheLoader<String,CachedSubscription>

Throws:

javax.cache.integration.CacheLoaderException