| DomainFilterInterceptor |
Filters membership based on domain.
|
| EncryptInterceptor |
Adds encryption using a pre-shared key.
|
| FragmentationInterceptor |
The fragmentation interceptor splits up large messages into smaller messages and assembles them on the other end.
|
| FragmentationInterceptor.FragCollection |
Collection that holds the fragments of a message for reassembly.
|
| FragmentationInterceptor.FragKey |
Key used to identify a set of fragments belonging to the same original message.
|
| GzipInterceptor |
Channel interceptor that compresses messages using GZIP before transmission and decompresses
received messages.
|
| MessageDispatchInterceptor |
The message dispatcher is a way to enable asynchronous communication through a channel.
|
| NonBlockingCoordinator |
Title: Auto merging leader election algorithm
|
| NonBlockingCoordinator.CoordinationEvent |
Represents a coordination event in the election protocol.
|
| NonBlockingCoordinator.CoordinationMessage |
Represents a coordination message used in the election protocol.
|
| OrderInterceptor |
The order interceptor guarantees that messages are received in the same order they were sent.
|
| OrderInterceptor.Counter |
Counter for tracking message sequence numbers.
|
| OrderInterceptor.MessageOrder |
Represents a message in the ordering queue.
|
| SimpleCoordinator |
A dinky coordinator, just uses a sorted version of the member array.
|
| StaticMembershipInterceptor |
Channel interceptor that manages static membership for a cluster.
|
| TcpFailureDetector |
The TcpFailureDetector is a useful interceptor that adds reliability to the membership layer.
|
| TcpPingInterceptor |
Sends periodic TCP pings to cluster members for health monitoring.
|
| ThroughputInterceptor |
Interceptor that measures and reports message throughput statistics.
|
| TwoPhaseCommitInterceptor |
Two-phase commit interceptor that ensures reliable message delivery.
|
| TwoPhaseCommitInterceptor.MapEntry |
|