Modifier and Type | Method and Description |
---|---|
<T> T |
IReplicationNodePluginFacade.accept(AbstractReplicationPacket<T> packet) |
<T> T |
ReplicationNode.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 |
ConnectionReference.dispatch(AbstractReplicationPacket<T> packet) |
<T> T |
DisconnectionProxy.dispatch(AbstractReplicationPacket<T> packet) |
<T> T |
IReplicationConnectionProxy.dispatch(AbstractReplicationPacket<T> packet) |
<T> AsyncFuture<T> |
ConnectionReference.dispatchAsync(AbstractReplicationPacket<T> packet) |
<T> T |
DisconnectionProxy.dispatchAsync(AbstractReplicationPacket<T> packet) |
<T> T |
IReplicationConnectionProxy.dispatchAsync(AbstractReplicationPacket<T> packet) |
Copyright © GigaSpaces.