Manages distribution of various publisher operations that are ran locally and/or sent to remote nodes.
Handles locally publishing entries from the cache.
This is a special interface that can mark a Function so that a user can know if the actual value will change when the function is applied or not.
This is the same as
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.
Handles the submission and response handling of an arbitrary amount of address segments.
LocalPublisherManager that publishes entries from the local node only.
LocalPublisherManager that handles cases when a non segmented store are present.
Cluster stream manager that also pays attention to partition status and properly closes iterators and throws exceptions when the availability mode changes.
Handler for holding publisher results between requests of data
Enumeration defining the possible delivery guarantees for entries.
Copyright © 2021 JBoss by Red Hat. All rights reserved.