Package com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class LocalClusterReplicationSink.DelegatedConnection

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationSink.DelegatedConnection

All Implemented Interfaces:

IRouterStub, IReplicationConnectionProxy, Remote

Enclosing class:

LocalClusterReplicationSink

public class LocalClusterReplicationSink.DelegatedConnection
extends Object
implements IReplicationConnectionProxy

Constructor Summary

Constructors

Constructor	Description
DelegatedConnection(IReplicationConnectionProxy connectionProxy, String targetSpaceMemberLookupName)

Method Summary

Modifier and Type	Method	Description
protected void	cleanUp()
void	close()
<T> T	dispatch(AbstractReplicationPacket<T> packet)
<T> T	dispatchAsync(AbstractReplicationPacket<T> packet)
long	getLastTouched()
String	getTargetLookupName()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DelegatedConnection

public DelegatedConnection(IReplicationConnectionProxy connectionProxy,
 String targetSpaceMemberLookupName)

Method Details

getTargetLookupName

public String getTargetLookupName()

dispatch

public <T> T dispatch(AbstractReplicationPacket<T> packet)
               throws RemoteException

Specified by:

dispatch in interface IReplicationConnectionProxy

Throws:

RemoteException

dispatchAsync

public <T> T dispatchAsync(AbstractReplicationPacket<T> packet)
                    throws RemoteException

Specified by:

dispatchAsync in interface IReplicationConnectionProxy

Throws:

RemoteException

close

public void close()
           throws RemoteException

Specified by:

close in interface IReplicationConnectionProxy

Throws:

RemoteException

cleanUp

protected void cleanUp()
                throws RemoteException

Throws:

RemoteException

getLastTouched

public long getLastTouched()