Uses of Interface
org.infinispan.context.InvocationContext

Packages that use InvocationContext

Package	Description
org.infinispan.cache.impl
org.infinispan.commands	Commands that operate on the cache, either locally or remotely.
org.infinispan.container.impl	Data containers which store cache entries.
org.infinispan.context	Contexts contain information of a specific invocation on the cache, such as its origins, scope (transactional or non-transactional), as well as invocation-specific flags.
org.infinispan.context.impl	This package contains different context implementations, selected dynamically based on the type of invocation.
org.infinispan.distribution.group.impl
org.infinispan.expiration.impl
org.infinispan.extendedstats.topK
org.infinispan.extendedstats.wrappers
org.infinispan.functional.impl
org.infinispan.interceptors	Infinispan is designed around a set of interceptors around a data container.
org.infinispan.notifications.cachelistener	Cache-specific notifications and eventing.
org.infinispan.partitionhandling.impl
org.infinispan.persistence	Persistence API.
org.infinispan.persistence.internal
org.infinispan.persistence.support
org.infinispan.persistence.util
org.infinispan.reactive.publisher.impl
org.infinispan.stream.impl
org.infinispan.util.concurrent.locks	Lock and synchronization related classes, tools and utilities.
org.infinispan.util.concurrent.locks.impl

Uses of InvocationContext in org.infinispan.cache.impl

Methods in org.infinispan.cache.impl that return InvocationContext

Modifier and Type	Method	Description
InvocationContext	ContextBuilder.create(int keyCount)	Creates a new InvocationContext.
InvocationContext	InvocationHelper.createInvocationContextWithImplicitTransaction(int keyCount, boolean forceCreateTransaction)	Creates an invocation context with an implicit transaction if it is required.
protected InvocationContext	DecoratedCache.readContext(int size)
protected InvocationContext	DecoratedCache.writeContext(int size)

Methods in org.infinispan.cache.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
final Map<K,CacheEntry<K,V>>	CacheImpl.getAllCacheEntries(Set<?> keys, long explicitFlags, InvocationContext ctx)
<T> T	InvocationHelper.invoke(InvocationContext context, VisitableCommand command)	Invokes the command using context.
<T> CompletableFuture<T>	InvocationHelper.invokeAsync(InvocationContext context, VisitableCommand command)	Invokes the command using context and returns a CompletableFuture.

Uses of InvocationContext in org.infinispan.commands

Methods in org.infinispan.commands with parameters of type InvocationContext

Modifier and Type	Method	Description
Object	VisitableCommand.acceptVisitor(InvocationContext ctx, Visitor visitor)	Accept a visitor, and return the result of accepting this visitor.
protected Object	AbstractVisitor.handleDefault(InvocationContext ctx, VisitableCommand command)	A default handler for all commands visited.
Object	AbstractVisitor.visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
Object	Visitor.visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
void	AbstractVisitor.visitCollection(InvocationContext ctx, Collection<? extends VisitableCommand> toVisit)	Helper method to visit a collection of VisitableCommands.
Object	AbstractVisitor.visitComputeCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeCommand command)
Object	Visitor.visitComputeCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeCommand command)
Object	AbstractVisitor.visitComputeIfAbsentCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeIfAbsentCommand command)
Object	Visitor.visitComputeIfAbsentCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeIfAbsentCommand command)
Object	AbstractVisitor.visitEntrySetCommand(InvocationContext ctx, org.infinispan.commands.read.EntrySetCommand command)
Object	Visitor.visitEntrySetCommand(InvocationContext ctx, org.infinispan.commands.read.EntrySetCommand command)
Object	AbstractVisitor.visitEvictCommand(InvocationContext ctx, org.infinispan.commands.write.EvictCommand command)
Object	Visitor.visitEvictCommand(InvocationContext ctx, org.infinispan.commands.write.EvictCommand command)
Object	AbstractVisitor.visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
Object	Visitor.visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
Object	AbstractVisitor.visitGetCacheEntryCommand(InvocationContext ctx, org.infinispan.commands.read.GetCacheEntryCommand command)
Object	Visitor.visitGetCacheEntryCommand(InvocationContext ctx, org.infinispan.commands.read.GetCacheEntryCommand command)
Object	AbstractVisitor.visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	Visitor.visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	AbstractVisitor.visitInvalidateCommand(InvocationContext ctx, org.infinispan.commands.write.InvalidateCommand invalidateCommand)
Object	Visitor.visitInvalidateCommand(InvocationContext ctx, org.infinispan.commands.write.InvalidateCommand invalidateCommand)
Object	AbstractVisitor.visitInvalidateL1Command(InvocationContext ctx, org.infinispan.commands.write.InvalidateL1Command invalidateL1Command)
Object	Visitor.visitInvalidateL1Command(InvocationContext ctx, org.infinispan.commands.write.InvalidateL1Command invalidateL1Command)
Object	AbstractVisitor.visitIracPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.IracPutKeyValueCommand command)
Object	Visitor.visitIracPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.IracPutKeyValueCommand command)
Object	AbstractVisitor.visitKeySetCommand(InvocationContext ctx, org.infinispan.commands.read.KeySetCommand command)
Object	Visitor.visitKeySetCommand(InvocationContext ctx, org.infinispan.commands.read.KeySetCommand command)
Object	AbstractVisitor.visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
Object	Visitor.visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
Object	AbstractVisitor.visitPutMapCommand(InvocationContext ctx, org.infinispan.commands.write.PutMapCommand command)
Object	Visitor.visitPutMapCommand(InvocationContext ctx, org.infinispan.commands.write.PutMapCommand command)
Object	AbstractVisitor.visitReadOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyKeyCommand command)
Object	Visitor.visitReadOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyKeyCommand command)
Object	AbstractVisitor.visitReadOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyManyCommand command)
Object	Visitor.visitReadOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyManyCommand command)
Object	AbstractVisitor.visitReadWriteKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyCommand command)
Object	Visitor.visitReadWriteKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyCommand command)
Object	AbstractVisitor.visitReadWriteKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyValueCommand command)
Object	Visitor.visitReadWriteKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyValueCommand command)
Object	AbstractVisitor.visitReadWriteManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyCommand command)
Object	Visitor.visitReadWriteManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyCommand command)
Object	AbstractVisitor.visitReadWriteManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyEntriesCommand command)
Object	Visitor.visitReadWriteManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyEntriesCommand command)
Object	AbstractVisitor.visitRemoveCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
Object	Visitor.visitRemoveCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
default Object	Visitor.visitRemoveExpiredCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveExpiredCommand command)
Object	AbstractVisitor.visitReplaceCommand(InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)
Object	Visitor.visitReplaceCommand(InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)
Object	AbstractVisitor.visitSizeCommand(InvocationContext ctx, org.infinispan.commands.read.SizeCommand command)
Object	Visitor.visitSizeCommand(InvocationContext ctx, org.infinispan.commands.read.SizeCommand command)
Object	AbstractVisitor.visitTouchCommand(InvocationContext ctx, TouchCommand command)
Object	Visitor.visitTouchCommand(InvocationContext ctx, TouchCommand command)
Object	AbstractVisitor.visitUnknownCommand(InvocationContext ctx, VisitableCommand command)
Object	Visitor.visitUnknownCommand(InvocationContext ctx, VisitableCommand command)	Deprecated, for removal: This API element is subject to removal in a future version. since 11.0 will be removed in the next major version with no direct replacement.
Object	AbstractVisitor.visitWriteOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyCommand command)
Object	Visitor.visitWriteOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyCommand command)
Object	AbstractVisitor.visitWriteOnlyKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)
Object	Visitor.visitWriteOnlyKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)
Object	AbstractVisitor.visitWriteOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyCommand command)
Object	Visitor.visitWriteOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyCommand command)
Object	AbstractVisitor.visitWriteOnlyManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyEntriesCommand command)
Object	Visitor.visitWriteOnlyManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyEntriesCommand command)

Uses of InvocationContext in org.infinispan.container.impl

Methods in org.infinispan.container.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
<K, V> InternalCacheValue<V>	InternalEntryFactory.getValueFromCtx(K key, InvocationContext ctx)	Retrieve an InternalCacheValue from the provided InvocationContext if an InternalCacheEntry exists, otherwise create InternalCacheEntry from the context's CacheEntry and return its value.
<K, V> InternalCacheValue<V>	InternalEntryFactoryImpl.getValueFromCtx(K key, InvocationContext ctx)
CompletionStage<Void>	EntryFactory.wrapEntryForReading(InvocationContext ctx, Object key, int segment, boolean isOwner, boolean hasLock, CompletionStage<Void> previousStage)	Wraps an entry for reading.
final CompletionStage<Void>	EntryFactoryImpl.wrapEntryForReading(InvocationContext ctx, Object key, int segment, boolean isOwner, boolean hasLock, CompletionStage<Void> previousStage)
CompletionStage<Void>	EntryFactory.wrapEntryForWriting(InvocationContext ctx, Object key, int segment, boolean isOwner, boolean isRead, CompletionStage<Void> previousStage)	Insert an entry that exists in the data container into the context.
CompletionStage<Void>	EntryFactoryImpl.wrapEntryForWriting(InvocationContext ctx, Object key, int segment, boolean isOwner, boolean isRead, CompletionStage<Void> previousStage)
void	EntryFactory.wrapEntryForWritingSkipExpiration(InvocationContext ctx, Object key, int segment, boolean isOwner)	Insert an entry that exists in the data container into the context, even if it is expired Doesn't do anything if the key was already wrapped
void	EntryFactoryImpl.wrapEntryForWritingSkipExpiration(InvocationContext ctx, Object key, int segment, boolean isOwner)
void	EntryFactory.wrapExternalEntry(InvocationContext ctx, Object key, CacheEntry externalEntry, boolean isRead, boolean isWrite)	Insert an external entry (e.g.
void	EntryFactoryImpl.wrapExternalEntry(InvocationContext ctx, Object key, CacheEntry externalEntry, boolean isRead, boolean isWrite)

Uses of InvocationContext in org.infinispan.context

Methods in org.infinispan.context that return InvocationContext

Modifier and Type	Method	Description
InvocationContext	InvocationContext.clone()	Clones the invocation context.
InvocationContext	InvocationContextFactory.createClearNonTxInvocationContext()	Will create an ClearInvocationContext with the AbstractInvocationContext.isOriginLocal() returning true.
InvocationContext	InvocationContextFactory.createInvocationContext(boolean isWrite, int keyCount)	If we are in a tx scope this will return an TxInvocationContext.
InvocationContext	InvocationContextFactory.createInvocationContext(javax.transaction.Transaction tx, boolean implicitTransaction)	Creates an invocation context
InvocationContext	InvocationContextFactory.createRemoteInvocationContext(Address origin)	Returns an NonTxInvocationContext whose AbstractInvocationContext.isOriginLocal() flag will be true.
InvocationContext	InvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand, Address origin)	As InvocationContextFactory.createRemoteInvocationContext(org.infinispan.remoting.transport.Address), but returning the flags to the context from the Command if any Flag was set.
InvocationContext	InvocationContextFactory.createSingleKeyNonTxInvocationContext()	Will create an NonTxInvocationContext with the AbstractInvocationContext.isOriginLocal() returning true.

Uses of InvocationContext in org.infinispan.context.impl

Subinterfaces of InvocationContext in org.infinispan.context.impl

Modifier and Type	Interface	Description
interface	TxInvocationContext<T extends AbstractCacheTransaction>	Interface defining additional functionality for invocation contexts that propagate within a transaction's scope.

Classes in org.infinispan.context.impl that implement InvocationContext

Modifier and Type	Class	Description
class	AbstractInvocationContext	Common features of transaction and invocation contexts
class	AbstractTxInvocationContext<T extends AbstractCacheTransaction>	Support class for TxInvocationContext.
class	ClearInvocationContext	Implementation of InvocationContext used by the ClearCommand.
final class	ImmutableContext	This context is a non-context for operations such as eviction which are not related to the method invocation which caused them.
class	LocalTxInvocationContext	Invocation context to be used for locally originated transactions.
class	NonTxInvocationContext	Context to be used for non transactional calls, both remote and local.
class	RemoteTxInvocationContext	Context to be used for transaction that originated remotely.
final class	SingleKeyNonTxInvocationContext

Methods in org.infinispan.context.impl that return InvocationContext

Modifier and Type	Method	Description
InvocationContext	AbstractInvocationContext.clone()
InvocationContext	ImmutableContext.clone()
InvocationContext	SingleKeyNonTxInvocationContext.clone()
final InvocationContext	AbstractInvocationContextFactory.createClearNonTxInvocationContext()
InvocationContext	NonTransactionalInvocationContextFactory.createInvocationContext(boolean isWrite, int keyCount)
InvocationContext	NonTransactionalInvocationContextFactory.createInvocationContext(javax.transaction.Transaction tx, boolean implicitTransaction)
InvocationContext	TransactionalInvocationContextFactory.createInvocationContext(boolean isWrite, int keyCount)
InvocationContext	TransactionalInvocationContextFactory.createInvocationContext(javax.transaction.Transaction tx, boolean implicitTransaction)
InvocationContext	AbstractInvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand, Address origin)
InvocationContext	NonTransactionalInvocationContextFactory.createSingleKeyNonTxInvocationContext()
InvocationContext	TransactionalInvocationContextFactory.createSingleKeyNonTxInvocationContext()

Methods in org.infinispan.context.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
static Flag	FlagBitSets.extractStateTransferFlag(InvocationContext ctx, FlagAffectedCommand command)

Uses of InvocationContext in org.infinispan.distribution.group.impl

Methods in org.infinispan.distribution.group.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
<K, V> Map<K,V>	GroupManager.collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)	Collects all entries belonging to a single group.
<K, V> Map<K,V>	GroupManagerImpl.collect(CacheStream<? extends CacheEntry<K,V>> stream, InvocationContext ctx, String groupName)

Uses of InvocationContext in org.infinispan.expiration.impl

Methods in org.infinispan.expiration.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
Object	TouchCommand.acceptVisitor(InvocationContext ctx, Visitor visitor)

Uses of InvocationContext in org.infinispan.extendedstats.topK

Methods in org.infinispan.extendedstats.topK with parameters of type InvocationContext

Modifier and Type	Method	Description
Object	CacheUsageInterceptor.visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
Object	CacheUsageInterceptor.visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	CacheUsageInterceptor.visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)

Uses of InvocationContext in org.infinispan.extendedstats.wrappers

Methods in org.infinispan.extendedstats.wrappers with parameters of type InvocationContext

Modifier and Type	Method	Description
void	ExtendedStatisticLockManager.unlockAll(InvocationContext ctx)
void	TopKeyLockManager.unlockAll(InvocationContext ctx)
Object	ExtendedStatisticInterceptor.visitComputeCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeCommand command)
Object	ExtendedStatisticInterceptor.visitComputeIfAbsentCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeIfAbsentCommand command)
Object	ExtendedStatisticInterceptor.visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
Object	ExtendedStatisticInterceptor.visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	ExtendedStatisticInterceptor.visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
Object	ExtendedStatisticInterceptor.visitReadWriteKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyCommand command)
Object	ExtendedStatisticInterceptor.visitRemoveCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
Object	ExtendedStatisticInterceptor.visitReplaceCommand(InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)

Uses of InvocationContext in org.infinispan.functional.impl

Methods in org.infinispan.functional.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
static Object	StatsEnvelope.unpack(InvocationContext ctx, VisitableCommand command, Object o)
static Object	StatsEnvelope.unpackCollection(InvocationContext ctx, VisitableCommand command, Object o)
static Object	StatsEnvelope.unpackStream(InvocationContext ctx, VisitableCommand command, Object o)

Uses of InvocationContext in org.infinispan.interceptors

Methods in org.infinispan.interceptors with parameters of type InvocationContext

Modifier and Type	Method	Description
void	InvocationFinallyAction.accept(InvocationContext rCtx, C rCommand, Object rv, Throwable throwable)	Process the result or the exception from an invocation stage and possibly throw an exception.
void	InvocationSuccessAction.accept(InvocationContext rCtx, C rCommand, Object rv)	Process the result from a successful invocation stage and possibly throw an exception.
Object	ExceptionSyncInvocationStage.addCallback(InvocationContext ctx, VisitableCommand command, InvocationCallback function)
abstract <C extends VisitableCommand> Object	InvocationStage.addCallback(InvocationContext ctx, C command, InvocationCallback<C> function)	After the current stage completes, invoke function and return its result.
<C extends VisitableCommand> Object	SyncInvocationStage.addCallback(InvocationContext ctx, C command, InvocationCallback<C> function)
Object	ExceptionSyncInvocationStage.andExceptionally(InvocationContext ctx, VisitableCommand command, InvocationExceptionFunction function)
<C extends VisitableCommand> Object	InvocationStage.andExceptionally(InvocationContext ctx, C command, InvocationExceptionFunction<C> function)	After the current stage completes exceptionally, invoke function and return its result.
<C extends VisitableCommand> Object	SyncInvocationStage.andExceptionally(InvocationContext ctx, C command, InvocationExceptionFunction<C> function)
<C extends VisitableCommand> InvocationStage	InvocationStage.andExceptionallyMakeStage(InvocationContext ctx, C command, InvocationExceptionFunction<C> function)	After the current stage completes exceptionally, invoke function and return its result.
<C extends VisitableCommand> InvocationStage	SyncInvocationStage.andExceptionallyMakeStage(InvocationContext ctx, C command, InvocationExceptionFunction<C> function)
Object	ExceptionSyncInvocationStage.andFinally(InvocationContext ctx, VisitableCommand command, InvocationFinallyAction action)
<C extends VisitableCommand> Object	InvocationStage.andFinally(InvocationContext ctx, C command, InvocationFinallyAction<C> action)	After the current stage completes, invoke action.
<C extends VisitableCommand> Object	SyncInvocationStage.andFinally(InvocationContext ctx, C command, InvocationFinallyAction<C> action)
<C extends VisitableCommand> InvocationStage	InvocationStage.andFinallyMakeStage(InvocationContext ctx, C command, InvocationFinallyAction<C> action)	After the current stage completes, invoke action.
<C extends VisitableCommand> InvocationStage	SyncInvocationStage.andFinallyMakeStage(InvocationContext ctx, C command, InvocationFinallyAction<C> action)
Object	ExceptionSyncInvocationStage.andHandle(InvocationContext ctx, VisitableCommand command, InvocationFinallyFunction function)
<C extends VisitableCommand> Object	InvocationStage.andHandle(InvocationContext ctx, C command, InvocationFinallyFunction<C> function)	After the current stage completes, invoke function and return its result.
<C extends VisitableCommand> Object	SyncInvocationStage.andHandle(InvocationContext ctx, C command, InvocationFinallyFunction<C> function)
<C extends VisitableCommand> InvocationStage	InvocationStage.andHandleMakeStage(InvocationContext ctx, C command, InvocationFinallyFunction<C> function)	After the current stage completes, invoke function and return its result.
<C extends VisitableCommand> InvocationStage	SyncInvocationStage.andHandleMakeStage(InvocationContext ctx, C command, InvocationFinallyFunction<C> function)
Object	InvocationCallback.apply(InvocationContext rCtx, C rCommand, Object rv, Throwable throwable)	Process the result or the exception from an invocation stage and either return a simple value, return a new InvocationStage, or throw an exception.
default Object	InvocationExceptionFunction.apply(InvocationContext rCtx, C rCommand, Object rv, Throwable throwable)
Object	InvocationExceptionFunction.apply(InvocationContext rCtx, C rCommand, Throwable throwable)	Process the result from a successful invocation stage and either return a simple value, return a new InvocationStage, or throw an exception.
default Object	InvocationFinallyAction.apply(InvocationContext rCtx, C rCommand, Object rv, Throwable throwable)
default Object	InvocationSuccessAction.apply(InvocationContext rCtx, C rCommand, Object rv, Throwable throwable)
Object	InvocationSuccessFunction.apply(InvocationContext rCtx, C rCommand, Object rv)	Process the result from a successful invocation stage and either return a simple value, return a new InvocationStage, or throw an exception.
default Object	InvocationSuccessFunction.apply(InvocationContext rCtx, C rCommand, Object rv, Throwable throwable)
final Object	BaseAsyncInterceptor.asyncInvokeNext(InvocationContext ctx, VisitableCommand command, Collection<? extends CompletionStage<?>> delays)	Suspend invocation until all delays complete, then if successful invoke the next interceptor.
final Object	BaseAsyncInterceptor.asyncInvokeNext(InvocationContext ctx, VisitableCommand command, CompletionStage<?> delay)	Suspend the invocation until delay completes, then if successful invoke the next interceptor.
final Object	BaseAsyncInterceptor.asyncInvokeNext(InvocationContext ctx, VisitableCommand command, InvocationStage invocationStage)	Suspend the invocation until invocationStage completes, then if successful invoke the next interceptor.
protected Object	DDAsyncInterceptor.handleDefault(InvocationContext ctx, VisitableCommand command)
Object	AsyncInterceptorChain.invoke(InvocationContext ctx, VisitableCommand command)	Walks the command through the interceptor chain.
Object	EmptyAsyncInterceptorChain.invoke(InvocationContext ctx, VisitableCommand command)
CompletableFuture<Object>	AsyncInterceptorChain.invokeAsync(InvocationContext ctx, VisitableCommand command)	Walks the command through the interceptor chain.
CompletableFuture<Object>	EmptyAsyncInterceptorChain.invokeAsync(InvocationContext ctx, VisitableCommand command)
final Object	BaseAsyncInterceptor.invokeNext(InvocationContext ctx, VisitableCommand command)	Invoke the next interceptor, possibly with a new command.
final <C extends VisitableCommand> Object	BaseAsyncInterceptor.invokeNextAndExceptionally(InvocationContext ctx, C command, InvocationExceptionFunction<C> function)	Invoke the next interceptor, possibly with a new command, and execute an InvocationCallback after all the interceptors have finished with an exception.
final <C extends VisitableCommand> Object	BaseAsyncInterceptor.invokeNextAndFinally(InvocationContext ctx, C command, InvocationFinallyAction<C> action)	Invoke the next interceptor, possibly with a new command, and execute an InvocationCallback after all the interceptors have finished, with or without an exception.
final <C extends VisitableCommand> Object	BaseAsyncInterceptor.invokeNextAndHandle(InvocationContext ctx, C command, InvocationFinallyFunction<C> function)	Invoke the next interceptor, possibly with a new command, and execute an InvocationCallback after all the interceptors have finished, with or without an exception.
final <C extends VisitableCommand> Object	BaseAsyncInterceptor.invokeNextThenAccept(InvocationContext ctx, C command, InvocationSuccessAction<C> action)	Invoke the next interceptor, possibly with a new command, and execute an InvocationCallback after all the interceptors have finished successfully.
final <C extends VisitableCommand> Object	BaseAsyncInterceptor.invokeNextThenApply(InvocationContext ctx, C command, InvocationSuccessFunction<C> function)	Invoke the next interceptor, possibly with a new command, and execute an InvocationCallback after all the interceptors have finished successfully.
InvocationStage	AsyncInterceptorChain.invokeStage(InvocationContext ctx, VisitableCommand command)	Walks the command through the interceptor chain.
InvocationStage	EmptyAsyncInterceptorChain.invokeStage(InvocationContext ctx, VisitableCommand command)
Object	ExceptionSyncInvocationStage.thenAccept(InvocationContext ctx, VisitableCommand command, InvocationSuccessAction function)
<C extends VisitableCommand> Object	InvocationStage.thenAccept(InvocationContext ctx, C command, InvocationSuccessAction<C> action)	After the current stage completes successfully, invoke action.
<C extends VisitableCommand> Object	SyncInvocationStage.thenAccept(InvocationContext ctx, C command, InvocationSuccessAction<C> action)
<C extends VisitableCommand> InvocationStage	InvocationStage.thenAcceptMakeStage(InvocationContext ctx, C command, InvocationSuccessAction<C> action)	After the current stage completes successfully, invoke action.
<C extends VisitableCommand> InvocationStage	SyncInvocationStage.thenAcceptMakeStage(InvocationContext ctx, C command, InvocationSuccessAction<C> action)
Object	ExceptionSyncInvocationStage.thenApply(InvocationContext ctx, VisitableCommand command, InvocationSuccessFunction function)
<C extends VisitableCommand> Object	InvocationStage.thenApply(InvocationContext ctx, C command, InvocationSuccessFunction<C> function)	After the current stage completes successfully, invoke function and return its result.
<C extends VisitableCommand> Object	SyncInvocationStage.thenApply(InvocationContext ctx, C command, InvocationSuccessFunction<C> function)
<C extends VisitableCommand> InvocationStage	InvocationStage.thenApplyMakeStage(InvocationContext ctx, C command, InvocationSuccessFunction<C> function)	After the current stage completes successfully, invoke function and return its result.
<C extends VisitableCommand> InvocationStage	SyncInvocationStage.thenApplyMakeStage(InvocationContext ctx, C command, InvocationSuccessFunction<C> function)	After the current stage completes successfully, invoke function and return its result.
Object	ExceptionSyncInvocationStage.thenReturn(InvocationContext ctx, VisitableCommand command, Object returnValue)
Object	InvocationStage.thenReturn(InvocationContext ctx, VisitableCommand command, Object returnValue)	Overrides the return value of this InvocationStage if it is completed successfully.
Object	SyncInvocationStage.thenReturn(InvocationContext ctx, VisitableCommand command, Object returnValue)
Object	DDAsyncInterceptor.visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
Object	AsyncInterceptor.visitCommand(InvocationContext ctx, VisitableCommand command)	Perform some work for a command invocation.
final Object	DDAsyncInterceptor.visitCommand(InvocationContext ctx, VisitableCommand command)
Object	DDAsyncInterceptor.visitComputeCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeCommand command)
Object	DDAsyncInterceptor.visitComputeIfAbsentCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeIfAbsentCommand command)
Object	DDAsyncInterceptor.visitEntrySetCommand(InvocationContext ctx, org.infinispan.commands.read.EntrySetCommand command)
Object	DDAsyncInterceptor.visitEvictCommand(InvocationContext ctx, org.infinispan.commands.write.EvictCommand command)
Object	DDAsyncInterceptor.visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
Object	DDAsyncInterceptor.visitGetCacheEntryCommand(InvocationContext ctx, org.infinispan.commands.read.GetCacheEntryCommand command)
Object	DDAsyncInterceptor.visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	DDAsyncInterceptor.visitInvalidateCommand(InvocationContext ctx, org.infinispan.commands.write.InvalidateCommand command)
Object	DDAsyncInterceptor.visitInvalidateL1Command(InvocationContext ctx, org.infinispan.commands.write.InvalidateL1Command command)
Object	DDAsyncInterceptor.visitIracPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.IracPutKeyValueCommand command)
Object	DDAsyncInterceptor.visitKeySetCommand(InvocationContext ctx, org.infinispan.commands.read.KeySetCommand command)
Object	DDAsyncInterceptor.visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
Object	DDAsyncInterceptor.visitPutMapCommand(InvocationContext ctx, org.infinispan.commands.write.PutMapCommand command)
Object	DDAsyncInterceptor.visitReadOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyKeyCommand command)
Object	DDAsyncInterceptor.visitReadOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadOnlyManyCommand command)
Object	DDAsyncInterceptor.visitReadWriteKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyCommand command)
Object	DDAsyncInterceptor.visitReadWriteKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyValueCommand command)
Object	DDAsyncInterceptor.visitReadWriteManyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyCommand command)
Object	DDAsyncInterceptor.visitReadWriteManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteManyEntriesCommand command)
Object	DDAsyncInterceptor.visitRemoveCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
Object	DDAsyncInterceptor.visitReplaceCommand(InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)
Object	DDAsyncInterceptor.visitSizeCommand(InvocationContext ctx, org.infinispan.commands.read.SizeCommand command)
Object	DDAsyncInterceptor.visitTouchCommand(InvocationContext ctx, TouchCommand command)
Object	DDAsyncInterceptor.visitUnknownCommand(InvocationContext ctx, VisitableCommand command)
Object	DDAsyncInterceptor.visitWriteOnlyKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyCommand command)
Object	DDAsyncInterceptor.visitWriteOnlyKeyValueCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyKeyValueCommand command)
Object	DDAsyncInterceptor.visitWriteOnlyManyCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyCommand command)
Object	DDAsyncInterceptor.visitWriteOnlyManyEntriesCommand(InvocationContext ctx, org.infinispan.commands.functional.WriteOnlyManyEntriesCommand command)

Uses of InvocationContext in org.infinispan.notifications.cachelistener

Methods in org.infinispan.notifications.cachelistener with parameters of type InvocationContext

Modifier and Type	Method	Description
static CompletionStage<Void>	NotifyHelper.entryCommitted(CacheNotifier notifier, FunctionalNotifier functionalNotifier, boolean created, boolean removed, boolean expired, CacheEntry entry, InvocationContext ctx, FlagAffectedCommand command, Object previousValue, Metadata previousMetadata, EvictionManager evictionManager)
CompletionStage<Void>	CacheNotifier.notifyCacheEntriesEvicted(Collection<Map.Entry<K,V>> entries, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntriesEvictedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntriesEvicted(Collection<Map.Entry<K,V>> entries, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryActivated(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryActivatedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryActivated(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryCreated(K key, V value, Metadata metadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryCreatedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryCreated(K key, V value, Metadata metadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryExpired(K key, V value, Metadata metadata, InvocationContext ctx)	Notifies all registered listeners of a CacheEntryExpired event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryExpired(K key, V value, Metadata metadata, InvocationContext ctx)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryInvalidated(K key, V value, Metadata metadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryInvalidatedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryInvalidated(K key, V value, Metadata metadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryLoaded(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryLoadedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryLoaded(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryModified(K key, V value, Metadata metadata, V previousValue, Metadata previousMetadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryModifiedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryModified(K key, V value, Metadata metadata, V previousValue, Metadata previousMetadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryPassivated(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryPassivatedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryPassivated(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryRemoved(K key, V previousValue, Metadata previousMetadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryRemovedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryRemoved(K key, V previousValue, Metadata previousMetadata, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyCacheEntryVisited(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)	Notifies all registered listeners of a CacheEntryVisitedEvent event.
CompletionStage<Void>	CacheNotifierImpl.notifyCacheEntryVisited(K key, V value, boolean pre, InvocationContext ctx, FlagAffectedCommand command)
CompletionStage<Void>	CacheNotifier.notifyTransactionCompleted(GlobalTransaction transaction, boolean successful, InvocationContext ctx)	Notifies all registered listeners of a transaction completion event.
CompletionStage<Void>	CacheNotifierImpl.notifyTransactionCompleted(GlobalTransaction transaction, boolean successful, InvocationContext ctx)

Uses of InvocationContext in org.infinispan.partitionhandling.impl

Methods in org.infinispan.partitionhandling.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
protected Object	PartitionHandlingInterceptor.handleSingleWrite(InvocationContext ctx, org.infinispan.commands.write.DataWriteCommand command)
protected void	PartitionHandlingInterceptor.postTxCommandCheck(InvocationContext rCtx, VisitableCommand rCommand, Object rv)
Object	PartitionHandlingInterceptor.visitClearCommand(InvocationContext ctx, org.infinispan.commands.write.ClearCommand command)
Object	PartitionHandlingInterceptor.visitComputeCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeCommand command)
Object	PartitionHandlingInterceptor.visitComputeIfAbsentCommand(InvocationContext ctx, org.infinispan.commands.write.ComputeIfAbsentCommand command)
Object	PartitionHandlingInterceptor.visitEntrySetCommand(InvocationContext ctx, org.infinispan.commands.read.EntrySetCommand command)
Object	PartitionHandlingInterceptor.visitGetAllCommand(InvocationContext ctx, org.infinispan.commands.read.GetAllCommand command)
final Object	PartitionHandlingInterceptor.visitGetCacheEntryCommand(InvocationContext ctx, org.infinispan.commands.read.GetCacheEntryCommand command)
final Object	PartitionHandlingInterceptor.visitGetKeyValueCommand(InvocationContext ctx, org.infinispan.commands.read.GetKeyValueCommand command)
Object	PartitionHandlingInterceptor.visitIracPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.IracPutKeyValueCommand command)
Object	PartitionHandlingInterceptor.visitKeySetCommand(InvocationContext ctx, org.infinispan.commands.read.KeySetCommand command)
Object	PartitionHandlingInterceptor.visitPutKeyValueCommand(InvocationContext ctx, org.infinispan.commands.write.PutKeyValueCommand command)
Object	PartitionHandlingInterceptor.visitPutMapCommand(InvocationContext ctx, org.infinispan.commands.write.PutMapCommand command)
Object	PartitionHandlingInterceptor.visitReadWriteKeyCommand(InvocationContext ctx, org.infinispan.commands.functional.ReadWriteKeyCommand command)
Object	PartitionHandlingInterceptor.visitRemoveCommand(InvocationContext ctx, org.infinispan.commands.write.RemoveCommand command)
Object	PartitionHandlingInterceptor.visitReplaceCommand(InvocationContext ctx, org.infinispan.commands.write.ReplaceCommand command)

Uses of InvocationContext in org.infinispan.persistence

Methods in org.infinispan.persistence with parameters of type InvocationContext

Modifier and Type	Method	Description
static <K, V> MarshallableEntry<K,V>	PersistenceUtil.loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager, Object key, InvocationContext context, TimeService timeService)	Deprecated, for removal: This API element is subject to removal in a future version. since 9.4 This method references PersistenceManager, which isn't a public class
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, DataContainer.ComputeAction<K,V> action)	Deprecated, for removal: This API element is subject to removal in a future version. since 9.4 This method references PersistenceManager, which isn't a public class
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)	Deprecated, for removal: This API element is subject to removal in a future version. since 9.4 This method references PersistenceManager, which isn't a public class
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)	Deprecated, for removal: This API element is subject to removal in a future version. since 9.4 This method references PersistenceManager, which isn't a public class

Uses of InvocationContext in org.infinispan.persistence.internal

Methods in org.infinispan.persistence.internal with parameters of type InvocationContext

Modifier and Type	Method	Description
static <K, V> MarshallableEntry<K,V>	PersistenceUtil.loadAndCheckExpiration(org.infinispan.persistence.manager.PersistenceManager persistenceManager, Object key, int segment, InvocationContext context)
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.loadAndComputeInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, DataContainer.ComputeAction<K,V> action)
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, int segment, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)
static <K, V> InternalCacheEntry<K,V>	PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer, org.infinispan.persistence.manager.PersistenceManager persistenceManager, K key, InvocationContext ctx, TimeService timeService, AtomicReference<Boolean> isLoaded)

Uses of InvocationContext in org.infinispan.persistence.support

Methods in org.infinispan.persistence.support with parameters of type InvocationContext

Modifier and Type	Method	Description
CompletionStage<Long>	DelegatingPersistenceManager.writeMapCommand(org.infinispan.commands.write.PutMapCommand putMapCommand, InvocationContext ctx, BiPredicate<? super org.infinispan.commands.write.PutMapCommand,Object> commandKeyPredicate)

Uses of InvocationContext in org.infinispan.persistence.util

Methods in org.infinispan.persistence.util with parameters of type InvocationContext

Modifier and Type	Method	Description
CompletionStage<InternalCacheEntry<K,V>>	EntryLoader.loadAndStoreInDataContainer(InvocationContext ctx, Object key, int segment, FlagAffectedCommand cmd)	Load and store the entry if present in the data container, returning the entry in the CompletionStage

Uses of InvocationContext in org.infinispan.reactive.publisher.impl

Methods in org.infinispan.reactive.publisher.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
<R> SegmentPublisherSupplier<R>	ClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)	Performs the given transformer on data in the cache, resulting in multiple values.
<R> SegmentPublisherSupplier<R>	ClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	LocalClusterPublisherManagerImpl.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	PartitionAwareClusterPublisherManager.entryPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	ClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Performs the given transformer and finalizer on data in the cache, resulting in a single value.
<R> CompletionStage<R>	ClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	LocalClusterPublisherManagerImpl.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	PartitionAwareClusterPublisherManager.entryReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> SegmentPublisherSupplier<R>	ClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)	Same as ClusterPublisherManager.entryPublisher(IntSet, Set, InvocationContext, long, DeliveryGuarantee, int, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> SegmentPublisherSupplier<R>	ClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	LocalClusterPublisherManagerImpl.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> SegmentPublisherSupplier<R>	PartitionAwareClusterPublisherManager.keyPublisher(IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, int batchSize, Function<? super org.reactivestreams.Publisher<K>,? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	ClusterPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)	Same as ClusterPublisherManager.entryReduction(boolean, IntSet, Set, InvocationContext, long, DeliveryGuarantee, Function, Function) except that the source publisher provided to the transformer is made up of keys only.
<R> CompletionStage<R>	ClusterPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	LocalClusterPublisherManagerImpl.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext invocationContext, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
<R> CompletionStage<R>	PartitionAwareClusterPublisherManager.keyReduction(boolean parallelPublisher, IntSet segments, Set<K> keysToInclude, InvocationContext ctx, long explicitFlags, DeliveryGuarantee deliveryGuarantee, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
CompletionStage<Long>	ClusterPublisherManager.sizePublisher(IntSet segments, InvocationContext ctx, long flags)
CompletionStage<Long>	ClusterPublisherManagerImpl.sizePublisher(IntSet segments, InvocationContext ctx, long flags)
CompletionStage<Long>	LocalClusterPublisherManagerImpl.sizePublisher(IntSet segments, InvocationContext ctx, long flags)

Uses of InvocationContext in org.infinispan.stream.impl

Fields in org.infinispan.stream.impl declared as InvocationContext

Modifier and Type	Field	Description
protected final InvocationContext	AbstractCacheStream.invocationContext

Constructors in org.infinispan.stream.impl with parameters of type InvocationContext

Modifier	Constructor	Description
protected	AbstractCacheStream(Address localAddress, boolean parallel, InvocationContext ctx, long explicitFlags, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction, ClusterPublisherManager<?,?> clusterPublisherManager)
	DistributedCacheStream(Address localAddress, boolean parallel, InvocationContext ctx, long explicitFlags, int distributedBatchSize, Executor executor, ComponentRegistry registry, Function<? super Original,?> toKeyFunction, ClusterPublisherManager<?,?> clusterPublisherManager)	Standard constructor requiring all pertinent information to properly utilize a distributed cache stream

Uses of InvocationContext in org.infinispan.util.concurrent.locks

Methods in org.infinispan.util.concurrent.locks with parameters of type InvocationContext

Modifier and Type	Method	Description
void	LockManager.unlockAll(InvocationContext context)	Same as unlockAll(context.getLockedKeys(), context.getKeyLockOwner();.

Uses of InvocationContext in org.infinispan.util.concurrent.locks.impl

Methods in org.infinispan.util.concurrent.locks.impl with parameters of type InvocationContext

Modifier and Type	Method	Description
void	DefaultLockManager.unlockAll(InvocationContext context)