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

Class AbstractProxyBasedReplicationMonitoredConnection<T,L>

java.lang.Object

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

All Implemented Interfaces:

IExceptionHandler

Direct Known Subclasses:

MemberProxyBasedReplicationMonitoredConnection, StubBasedReplicationMonitoredConnection, UrlProxyBasedReplicationMonitoredConnection

public abstract class AbstractProxyBasedReplicationMonitoredConnection<T,L>
extends Object
implements IExceptionHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	AbstractProxyBasedReplicationMonitoredConnection.StateChangedEvent

Constructor Summary

Constructors

Constructor	Description
AbstractProxyBasedReplicationMonitoredConnection(AbstractConnectionProxyBasedReplicationRouter<T,L> router, String targetLookupName, IReplicationConnectionProxy connectionProxy, T tag, String endpointLookupName, IConnectionMonitor<T,L> monitor, L url, ConnectionState state, Exception disconnectionReason, Uuid proxyId, IAsyncContextProvider asyncContextProvider)

Method Summary

Modifier and Type	Method	Description
void	addConnectivityCheckListener(IConnectivityCheckListener connectivityCheckListener)
void	addReference()
void	addStateListener(IConnectionStateListener listener)
<TR> TR	dispatch(AbstractReplicationPacket<TR> packet)
<TR> AsyncFuture<TR>	dispatchAsync(AbstractReplicationPacket<TR> packet)
String	dumpState()
Object	getClosestEndpointAddress()
ConnectionEndpointDetails	getClosestEndpointDetails()
PlatformLogicalVersion	getClosestEndpointLogicalVersion()
IReplicationConnectionProxy	getConnectionProxy()
Object	getConnectionUrl()
String	getFinalEndpointLookupName()
L	getFinderURL()
long	getGeneratedTraffic()
Exception	getLastDisconnectionReason()
Uuid	getProxyId()
long	getReceivedTraffic()
AbstractConnectionProxyBasedReplicationRouter<T,L>	getRouter()
ServiceID	getServiceId()
ConnectionState	getState()
Object	getStateLock()
T	getTag()
String	getTargetLookupName()
Long	getTimeOfDisconnection()
Throwable	handleException(Throwable ex, IFuture future)
boolean	isConnectionClosed()
protected abstract void	onClose()
void	removeConnectivityCheckListener(IConnectivityCheckListener connectivityCheckListener)
void	removeReference()
void	removeStateListener(IConnectionStateListener listener)
void	setConnected(IReplicationConnectionProxy proxy, T tag, String endPointLookupName, Uuid proxyId)
void	setDisconnected(Exception reason)
void	setLastDisconnectionReason(Exception exception)
abstract boolean	supportsConnectivityCheckEvents()
String	toString()
void	triggerSuccessfulConnectivityCheckEvent()

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractProxyBasedReplicationMonitoredConnection

public AbstractProxyBasedReplicationMonitoredConnection(AbstractConnectionProxyBasedReplicationRouter<T,L> router,
 String targetLookupName,
 IReplicationConnectionProxy connectionProxy,
 T tag,
 String endpointLookupName,
 IConnectionMonitor<T,L> monitor,
 L url,
 ConnectionState state,
 Exception disconnectionReason,
 Uuid proxyId,
 IAsyncContextProvider asyncContextProvider)

Method Details

getRouter

public AbstractConnectionProxyBasedReplicationRouter<T,L> getRouter()

isConnectionClosed

public boolean isConnectionClosed()

onClose

protected abstract void onClose()

dispatch

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

Throws:

RemoteException

dispatchAsync

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

Throws:

RemoteException

handleException

public Throwable handleException(Throwable ex,
 IFuture future)

Specified by:

handleException in interface IExceptionHandler

setConnected

public void setConnected(IReplicationConnectionProxy proxy,
 T tag,
 String endPointLookupName,
 Uuid proxyId)

setDisconnected

public void setDisconnected(Exception reason)

getState

public ConnectionState getState()

getFinderURL

public L getFinderURL()

getConnectionProxy

public IReplicationConnectionProxy getConnectionProxy()

getTargetLookupName

public String getTargetLookupName()

getFinalEndpointLookupName

public String getFinalEndpointLookupName()

addStateListener

public void addStateListener(IConnectionStateListener listener)

removeStateListener

public void removeStateListener(IConnectionStateListener listener)

removeConnectivityCheckListener

public void removeConnectivityCheckListener(IConnectivityCheckListener connectivityCheckListener)

addConnectivityCheckListener

public void addConnectivityCheckListener(IConnectivityCheckListener connectivityCheckListener)

removeReference

public void removeReference()

addReference

public void addReference()

getLastDisconnectionReason

public Exception getLastDisconnectionReason()

setLastDisconnectionReason

public void setLastDisconnectionReason(Exception exception)

getTag

public T getTag()

getServiceId

public ServiceID getServiceId()

getProxyId

public Uuid getProxyId()

getStateLock

public Object getStateLock()

getConnectionUrl

public Object getConnectionUrl()

dumpState

public String dumpState()

toString

public String toString()

Overrides:

toString in class Object

getGeneratedTraffic

public long getGeneratedTraffic()

getReceivedTraffic

public long getReceivedTraffic()

getClosestEndpointAddress

public Object getClosestEndpointAddress()

getClosestEndpointLogicalVersion

public PlatformLogicalVersion getClosestEndpointLogicalVersion()

getClosestEndpointDetails

public ConnectionEndpointDetails getClosestEndpointDetails()

triggerSuccessfulConnectivityCheckEvent

public void triggerSuccessfulConnectivityCheckEvent()

supportsConnectivityCheckEvents

public abstract boolean supportsConnectivityCheckEvents()

getTimeOfDisconnection

public Long getTimeOfDisconnection()