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 IReplicationConnectionProxyRemoteExceptionpublic <T> T dispatchAsync(AbstractReplicationPacket<T> packet) throws RemoteException
dispatchAsync in interface IReplicationConnectionProxyRemoteExceptionpublic void close()
throws RemoteException
close in interface IReplicationConnectionProxyRemoteExceptionprotected void cleanUp()
throws RemoteException
RemoteExceptionpublic long getLastTouched()
Copyright © GigaSpaces.