Uses of Interface
org.infinispan.reactive.publisher.impl.ClusterPublisherManager

Packages that use ClusterPublisherManager

Package	Description
org.infinispan.factories	Factories are internal components used to create other components based on a cache's configuration.
org.infinispan.reactive.publisher.impl
org.infinispan.stream.impl

Uses of ClusterPublisherManager in org.infinispan.factories

Methods in org.infinispan.factories that return types with arguments of type ClusterPublisherManager

Modifier and Type	Method	Description
ComponentRef<ClusterPublisherManager>	ComponentRegistry.getClusterPublisherManager()
ComponentRef<ClusterPublisherManager>	ComponentRegistry.getLocalClusterPublisherManager()

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

Classes in org.infinispan.reactive.publisher.impl that implement ClusterPublisherManager

Modifier and Type	Class	Description
class	ClusterPublisherManagerImpl<K,V>	ClusterPublisherManager that determines targets for the given segments and/or keys and then sends to local and remote nodes in parallel collecting results to be returned.
class	LocalClusterPublisherManagerImpl<K,V>
class	PartitionAwareClusterPublisherManager<K,V>	Cluster stream manager that also pays attention to partition status and properly closes iterators and throws exceptions when the availability mode changes.

Uses of ClusterPublisherManager in org.infinispan.stream.impl

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

Modifier and Type	Field	Description
protected final ClusterPublisherManager	AbstractCacheStream.cpm

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

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