Package org.infinispan.persistence.util

Class PersistenceManagerCloseableSupplier<K,V>

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable, java.util.function.Supplier<MarshalledEntry<K,V>>, CloseableSupplier<MarshalledEntry<K,V>>

@Deprecated
public class PersistenceManagerCloseableSupplier<K,V>
extends java.lang.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(java.util.concurrent.Executor executor, AdvancedCacheLoader<K,V> loader, java.util.function.Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata, long timeout, java.util.concurrent.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(java.util.concurrent.Executor executor,
                                           AdvancedCacheLoader<K,V> loader,
                                           java.util.function.Predicate<? super K> filter,
                                           boolean fetchValue,
                                           boolean fetchMetadata,
                                           long timeout,
                                           java.util.concurrent.TimeUnit unit,
                                           int maxQueue)

Deprecated.

Method Detail

get

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

Deprecated.

Specified by:

get in interface java.util.function.Supplier<K>

Throws:

TimeoutException

close

public void close()

Deprecated.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface CloseableSupplier<K>