| Modifier and Type | Method and Description | 
|---|---|
<T> T | 
ReplicationNode.accept(AbstractReplicationPacket<T> packet)  | 
<T> T | 
IReplicationNodePluginFacade.accept(AbstractReplicationPacket<T> packet)  | 
<T> T | 
ReplicationNode.onReplication(AbstractReplicationPacket<T> packet)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> T | 
ReplicationConnectionDelegator.ReverseConnection.dispatch(AbstractReplicationPacket<T> packet)  | 
<T> T | 
ReplicationConnectionDelegator.ReverseConnection.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
protected <T> T | 
ReplicationConnectionDelegator.onDispatch(AbstractReplicationPacket<T> packet)  | 
<T> T | 
ReplicationConnectionDelegator.onReplication(AbstractReplicationPacket<T> packet)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> T | 
LusExportedReplicationComponent.dispatch(AbstractReplicationPacket<T> packet)  | 
<T> T | 
LusExportedReplicationComponent.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
protected abstract <T> T | 
LusExportedReplicationComponent.onDispatch(AbstractReplicationPacket<T> packet)
Called once an incoming packet is dispatched 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
QueryRemoteClusterTopologyPacket  | 
class  | 
SinkEstablishConnectionPacket  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> T | 
LocalClusterReplicationSink.accept(AbstractReplicationPacket<T> packet)  | 
<T> T | 
LocalClusterReplicationSink.DelegatedConnection.dispatch(AbstractReplicationPacket<T> packet)  | 
<T> T | 
LocalClusterReplicationSink.DelegatedConnection.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
protected <T> T | 
ReplicationSink.onDispatch(AbstractReplicationPacket<T> packet)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
FetchReliableAsyncMissingMemberDataPacket  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SynchronizationDonePacket  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AbstractGroupNameReplicationPacket<T>  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> T | 
IReplicationConnection.dispatch(AbstractReplicationPacket<T> packet)  | 
<TR> TR | 
AbstractConnectionProxyBasedReplicationRouter.ConnectionEndpoint.dispatch(AbstractReplicationPacket<TR> packet)  | 
<TR> TR | 
AbstractProxyBasedReplicationMonitoredConnection.dispatch(AbstractReplicationPacket<TR> packet)  | 
<T> AsyncFuture<T> | 
IReplicationConnection.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
<TR> TR | 
AbstractConnectionProxyBasedReplicationRouter.ConnectionEndpoint.dispatchAsync(AbstractReplicationPacket<TR> packet)  | 
<TR> AsyncFuture<TR> | 
AbstractProxyBasedReplicationMonitoredConnection.dispatchAsync(AbstractReplicationPacket<TR> packet)  | 
<T> T | 
IIncomingReplicationHandler.onReplication(AbstractReplicationPacket<T> packet)
Handles incoming replication packet 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<T> T | 
DisconnectionProxy.dispatch(AbstractReplicationPacket<T> packet)  | 
<T> T | 
ConnectionReference.dispatch(AbstractReplicationPacket<T> packet)  | 
<T> T | 
IReplicationConnectionProxy.dispatch(AbstractReplicationPacket<T> packet)  | 
<T> T | 
DisconnectionProxy.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
<T> AsyncFuture<T> | 
ConnectionReference.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
<T> T | 
IReplicationConnectionProxy.dispatchAsync(AbstractReplicationPacket<T> packet)  | 
Copyright © GigaSpaces.