public class PhantomObjectsFilter extends Object implements IReplicationFilter
FILTER_DIRECTION_INPUT, FILTER_DIRECTION_OUTPUT
Constructor and Description |
---|
PhantomObjectsFilter() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this filter, enabling the developer to clean open resources.
|
void |
init(IJSpace space,
String paramUrl,
ReplicationPolicy replicationPolicy)
Initializes this filter.
|
void |
process(int direction,
IReplicationFilterEntry replicationFilterEntry,
String remoteSpaceMemberName)
Checks if the UID provided by read in the phantomTable then block it.
|
public void process(int direction, IReplicationFilterEntry replicationFilterEntry, String remoteSpaceMemberName)
process
in interface IReplicationFilter
direction
- IReplicationFilter.FILTER_DIRECTION_OUTPUT
or IReplicationFilter.FILTER_DIRECTION_INPUT
replicationFilterEntry
- replicated dataremoteSpaceMemberName
- name of the remote peer space (name format is
container-name:space-name)public void close() throws RuntimeException
IReplicationFilter
close
in interface IReplicationFilter
RuntimeException
public void init(IJSpace space, String paramUrl, ReplicationPolicy replicationPolicy)
IReplicationFilter
init
in interface IReplicationFilter
space
- an embedded proxy to the space that contain this filter.paramUrl
- the url that was passed when this filter was created.replicationPolicy
- replication policy for this replication groupCopyright © GigaSpaces.