public class LocalClusterReplicationSink.DelegatedConnection extends Object implements IReplicationConnectionProxy
Constructor and Description |
---|
DelegatedConnection(IReplicationConnectionProxy connectionProxy,
String targetSpaceMemberLookupName) |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanUp() |
void |
close() |
<T> T |
dispatch(AbstractReplicationPacket<T> packet) |
<T> T |
dispatchAsync(AbstractReplicationPacket<T> packet) |
long |
getLastTouched() |
String |
getTargetLookupName() |
public DelegatedConnection(IReplicationConnectionProxy connectionProxy, String targetSpaceMemberLookupName)
public String getTargetLookupName()
public <T> T dispatch(AbstractReplicationPacket<T> packet) throws RemoteException
dispatch
in interface IReplicationConnectionProxy
RemoteException
public <T> T dispatchAsync(AbstractReplicationPacket<T> packet) throws RemoteException
dispatchAsync
in interface IReplicationConnectionProxy
RemoteException
public void close() throws RemoteException
close
in interface IReplicationConnectionProxy
RemoteException
protected void cleanUp() throws RemoteException
RemoteException
public long getLastTouched()
Copyright © GigaSpaces.