Package org.infinispan.persistence.util

Class PersistenceManagerCloseableSupplier<K,V>

java.lang.Object

org.infinispan.persistence.util.PersistenceManagerCloseableSupplier<K,V>

All Implemented Interfaces:

AutoCloseable, Supplier<MarshalledEntry<K,V>>, CloseableSupplier<MarshalledEntry<K,V>>

@Deprecated
public class PersistenceManagerCloseableSupplier<K,V>
extends Object
implements CloseableSupplier<MarshalledEntry<K,V>>

Deprecated.

This class is to be removed when AdvancedCacheLoader.process(KeyFilter, AdvancedCacheLoader.CacheLoaderTask, Executor, boolean, boolean) is removed

A closeable supplier that provides a way to supply cache entries from a given persistence manager. On the first call to get this class will submit a task to collect all of the entries from the loader (or optionally a subset provided a given KeyFilter). A timeout value is required so that if a get blocks for the given timeout it will throw a TimeoutException.

Since:

8.0

Author:

William Burns

Constructor Summary

Constructors

Constructor	Description
PersistenceManagerCloseableSupplier(Executor executor, AdvancedCacheLoader<K,V> loader, Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, long timeout, TimeUnit unit, int maxQueue)	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	close()	Deprecated.
MarshalledEntry<K,V>	get()	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistenceManagerCloseableSupplier

public PersistenceManagerCloseableSupplier(Executor executor,
                                           AdvancedCacheLoader<K,V> loader,
                                           Predicate<? super K> filter,
                                           boolean fetchValue,
                                           boolean fetchMetadata,
                                           long timeout,
                                           TimeUnit unit,
                                           int maxQueue)

Deprecated.

Method Detail

get

public MarshalledEntry<K,V> get()
                               throws TimeoutException

Deprecated.

Specified by:

get in interface Supplier<K>

Throws:

TimeoutException

close

public void close()

Deprecated.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableSupplier<K>