| Package | Description |
|---|---|
| org.infinispan.remoting.inboundhandler |
Handling of inbound commands on remote nodes.
|
| org.infinispan.remoting.rpc |
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
|
| org.infinispan.remoting.transport |
Transports handle the low-level networking, used by the remoting components.
|
| org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
| Modifier and Type | Method and Description |
|---|---|
static DeliverOrder |
DeliverOrder.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static DeliverOrder[] |
DeliverOrder.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractDelegatingHandler.afterHandle(CacheRpcCommand command,
DeliverOrder order,
boolean delegated)
Invoked after the command is handled.
|
protected boolean |
AbstractDelegatingHandler.beforeHandle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Invoked before the command is handled by the real
PerCacheInboundInvocationHandler. |
void |
AbstractDelegatingHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
NonTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
PerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Handles the
CacheRpcCommand from other node. |
void |
TrianglePerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
TxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
GlobalInboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order) |
void |
InboundInvocationHandler.handleFromCluster(Address origin,
ReplicableCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from other node belonging to local site. |
void |
GlobalInboundInvocationHandler.handleFromRemoteSite(String origin,
XSiteReplicateCommand command,
Reply reply,
DeliverOrder order) |
void |
InboundInvocationHandler.handleFromRemoteSite(String origin,
XSiteReplicateCommand command,
Reply reply,
DeliverOrder order)
Handles the
ReplicableCommand from remote site. |
| Modifier and Type | Method and Description |
|---|---|
DeliverOrder |
RpcOptions.deliverOrder() |
| Modifier and Type | Method and Description |
|---|---|
void |
RpcManager.sendTo(Address destination,
ReplicableCommand command,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the destination using the specified DeliverOrder. |
void |
RpcManagerImpl.sendTo(Address destination,
ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
RpcManager.sendToAll(ReplicableCommand command,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the entire cluster. |
void |
RpcManagerImpl.sendToAll(ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
RpcManager.sendToMany(Collection<Address> destinations,
ReplicableCommand command,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the set of destination using the specified DeliverOrder. |
void |
RpcManagerImpl.sendToMany(Collection<Address> destinations,
ReplicableCommand command,
DeliverOrder deliverOrder) |
| Constructor and Description |
|---|
RpcOptions(DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
| Modifier and Type | Method and Description |
|---|---|
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a single node and pass the response to a
ResponseCollector. |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of node and pass the responses to a
ResponseCollector. |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(Collection<Address> requiredTargets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector. |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector. |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit) |
default <T> CompletionStage<T> |
Transport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit)
Invoke different commands on a collection of nodes and pass the responses to a
ResponseCollector. |
default <T> CompletionStage<T> |
Transport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> responseCollector,
long timeout,
DeliverOrder deliverOrder)
Deprecated.
Introduced in 9.1, but replaced in 9.2 with
Transport.invokeCommands(Collection, Function, ResponseCollector, DeliverOrder, long, TimeUnit). |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of nodes and pass the responses to a
ResponseCollector. |
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
|
default Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
Since 9.2, please use
Transport.invokeCommand(Collection, ReplicableCommand, ResponseCollector, DeliverOrder, long, TimeUnit) instead. |
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
|
default Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
Since 9.2, please use
Transport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder, boolean) instead. |
CompletableFuture<Map<Address,Response>> |
AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
Transport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
void |
AbstractDelegatingTransport.sendTo(Address destination,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder) |
void |
Transport.sendTo(Address destination,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the destination using the specified DeliverOrder. |
void |
AbstractDelegatingTransport.sendToAll(ReplicableCommand rpcCommand,
DeliverOrder deliverOrder) |
default void |
Transport.sendToAll(ReplicableCommand rpcCommand,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the entire cluster. |
void |
AbstractDelegatingTransport.sendToMany(Collection<Address> destinations,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder) |
void |
Transport.sendToMany(Collection<Address> destinations,
ReplicableCommand rpcCommand,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the set of destination using the specified DeliverOrder. |
| Modifier and Type | Method and Description |
|---|---|
<T> CompletionStage<T> |
JGroupsTransport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> commands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Deprecated.
|
CompletableFuture<Map<Address,Response>> |
JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand command,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
void |
JGroupsTransport.sendTo(Address destination,
ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
JGroupsTransport.sendToAll(ReplicableCommand command,
DeliverOrder deliverOrder) |
void |
JGroupsTransport.sendToMany(Collection<Address> targets,
ReplicableCommand command,
DeliverOrder deliverOrder) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.