Package com.gigaspaces.internal.cluster.node.impl.router.spacefinder

Class ConnectionReference<T,L>

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.router.spacefinder.ConnectionReference<T,L>

All Implemented Interfaces:

IReplicationConnection, IReplicationMonitoredConnection

public class ConnectionReference<T,L>
extends Object
implements IReplicationMonitoredConnection

Constructor Summary

Constructors

Constructor	Description
ConnectionReference(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)

Method Summary

Modifier and Type	Method	Description
void	close()
<T> T	dispatch(AbstractReplicationPacket<T> packet)
<T> AsyncFuture<T>	dispatchAsync(AbstractReplicationPacket<T> packet)
String	dumpState()
protected void	finalize()
Object	getClosestEndpointAddress()
ConnectionEndpointDetails	getClosestEndpointDetails()
PlatformLogicalVersion	getClosestEndpointLogicalVersion()
Uuid	getClosestEndpointUniqueId()
Object	getConnectionUrl()
String	getFinalEndpointLookupName()
long	getGeneratedTraffic()
Exception	getLastDisconnectionReason()
long	getReceivedTraffic()
ConnectionState	getState()
Long	getTimeOfDisconnection()
AbstractProxyBasedReplicationMonitoredConnection<T,L>	getUnderlyingConnection()
void	setConnectionStateListener(IConnectionStateListener listener)
void	setConnectivityCheckListener(IConnectivityCheckListener listener)
boolean	supportsConnectivityCheckEvents()

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionReference

public ConnectionReference(AbstractProxyBasedReplicationMonitoredConnection<T,L> connection)

Method Details

close

public void close()

Specified by:

close in interface IReplicationConnection

dispatch

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

Specified by:

dispatch in interface IReplicationConnection

Throws:

RemoteException

dispatchAsync

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

Specified by:

dispatchAsync in interface IReplicationConnection

Throws:

RemoteException

getState

public ConnectionState getState()

Specified by:

getState in interface IReplicationMonitoredConnection

setConnectionStateListener

public void setConnectionStateListener(IConnectionStateListener listener)

Specified by:

setConnectionStateListener in interface IReplicationMonitoredConnection

setConnectivityCheckListener

public void setConnectivityCheckListener(IConnectivityCheckListener listener)

Specified by:

setConnectivityCheckListener in interface IReplicationMonitoredConnection

getUnderlyingConnection

public AbstractProxyBasedReplicationMonitoredConnection<T,L> getUnderlyingConnection()

getLastDisconnectionReason

public Exception getLastDisconnectionReason()

Specified by:

getLastDisconnectionReason in interface IReplicationMonitoredConnection

Returns:

the reason for the last disconnection if any disconnection occurred. The reason does not reset when a connection is reestablished.

getFinalEndpointLookupName

public String getFinalEndpointLookupName()

Specified by:

getFinalEndpointLookupName in interface IReplicationConnection

Returns:

the final endpoint associated to this connection lookup name

getClosestEndpointUniqueId

public Uuid getClosestEndpointUniqueId()

Specified by:

getClosestEndpointUniqueId in interface IReplicationConnection

Returns:

the direct endpoint associated to this connection id, if delegators are used this will point to the directly connected delegator unique id and not the final destination unique id

getClosestEndpointAddress

public Object getClosestEndpointAddress()

Specified by:

getClosestEndpointAddress in interface IReplicationConnection

Returns:

the direct endpoint associated to this connection address, if delegators are used this will point to the directly connected delegator address and not the final destination address

getClosestEndpointDetails

public ConnectionEndpointDetails getClosestEndpointDetails()

Specified by:

getClosestEndpointDetails in interface IReplicationConnection

Returns:

the direct endpoint associated to this connection details

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

getConnectionUrl

public Object getConnectionUrl()

Specified by:

getConnectionUrl in interface IReplicationConnection

getGeneratedTraffic

public long getGeneratedTraffic()

Specified by:

getGeneratedTraffic in interface IReplicationConnection

getReceivedTraffic

public long getReceivedTraffic()

Specified by:

getReceivedTraffic in interface IReplicationConnection

getClosestEndpointLogicalVersion

public PlatformLogicalVersion getClosestEndpointLogicalVersion()

Specified by:

getClosestEndpointLogicalVersion in interface IReplicationConnection

Returns:

the direct endpoint associated to this connection logical version, if delegators are used this will point to the directly connected delegator logical version and not the final destination version

supportsConnectivityCheckEvents

public boolean supportsConnectivityCheckEvents()

Specified by:

supportsConnectivityCheckEvents in interface IReplicationMonitoredConnection

Returns:

whether IReplicationMonitoredConnection.setConnectivityCheckListener(IConnectivityCheckListener) listener is supported.

getTimeOfDisconnection

public Long getTimeOfDisconnection()

Specified by:

getTimeOfDisconnection in interface IReplicationMonitoredConnection

dumpState

public String dumpState()

Specified by:

dumpState in interface IReplicationMonitoredConnection