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

Packages that use ClusterPublisherManager

Package	Description
org.infinispan.reactive.publisher.impl
org.infinispan.stream.impl

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

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

Modifier and Type	Class and 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 and Description
protected ClusterPublisherManager	AbstractCacheStream.cpm