public class ClusterMarkingEntryFilter extends java.lang.Object implements WALEntryFilter
Constructor and Description |
---|
ClusterMarkingEntryFilter(java.util.UUID clusterId,
java.util.UUID peerClusterId,
ReplicationEndpoint replicationEndpoint) |
Modifier and Type | Method and Description |
---|---|
Entry |
filter(Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
public ClusterMarkingEntryFilter(java.util.UUID clusterId, java.util.UUID peerClusterId, ReplicationEndpoint replicationEndpoint)
clusterId
- id of this clusterpeerClusterId
- of the other clusterreplicationEndpoint
- ReplicationEndpoint which will handle the actual replicationpublic Entry filter(Entry entry)
WALEntryFilter
filter
in interface WALEntryFilter
entry
- Entry to filter