| org.apache.catalina.tribes.group.interceptors |
|
| Java Source File Name | Type | Comment |
| DomainFilterInterceptor.java | Class | Title: Member domain filter interceptor
Description: Filters membership based on domain. |
| FragmentationInterceptor.java | Class | The fragmentation interceptor splits up large messages into smaller messages and assembles them on the other end. |
| GzipInterceptor.java | Class | |
| MessageDispatch15Interceptor.java | Class | Same implementation as the MessageDispatchInterceptor
except is ues an atomic long for the currentSize calculation
and uses a thread pool for message sending. |
| MessageDispatchInterceptor.java | Class | The message dispatcher is a way to enable asynchronous communication
through a channel. |
| NonBlockingCoordinator.java | Class | Title: Auto merging leader election algorithm
Description: Implementation of a simple coordinator algorithm that not only selects a coordinator,
it also merges groups automatically when members are discovered that werent part of the
This algorithm is non blocking meaning it allows for transactions while the coordination phase is going on
This implementation is based on a home brewed algorithm that uses the AbsoluteOrder of a membership
to pass a token ring of the current membership.
This is not the same as just using AbsoluteOrder! Consider the following scenario:
Nodes, A,B,C,D,E on a network, in that priority. |
| OrderInterceptor.java | Class | The order interceptor guarantees that messages are received in the same order they were
sent.
This interceptor works best with the ack=true setting. |
| StaticMembershipInterceptor.java | Class | |
| TcpFailureDetector.java | Class | Title: A perfect failure detector
Description: The TcpFailureDetector is a useful interceptor
that adds reliability to the membership layer.
If the network is busy, or the system is busy so that the membership receiver thread
is not getting enough time to update its table, members can be "timed out"
This failure detector will intercept the memberDisappeared message(unless its a true shutdown message)
and connect to the member using TCP.
The TcpFailureDetector works in two ways. |
| TcpPingInterceptor.java | Class | Sends a ping to all members. |
| ThroughputInterceptor.java | Class | |
| TwoPhaseCommitInterceptor.java | Class | |