Package | Description |
---|---|
org.infinispan.remoting.inboundhandler | |
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.
|
org.infinispan.stats.wrappers |
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 . |
protected boolean |
BasePerCacheInboundInvocationHandler.executeOnExecutorService(DeliverOrder order,
CacheRpcCommand command) |
void |
TotalOrderTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
NonTotalOrderTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
AbstractDelegatingHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
NonTotalOrderPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
PerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Handles the
CacheRpcCommand from other node. |
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. |
protected void |
BasePerCacheInboundInvocationHandler.unexpectedDeliverMode(ReplicableCommand command,
DeliverOrder deliverOrder) |
Modifier and Type | Method and Description |
---|---|
DeliverOrder |
RpcOptions.deliverOrder() |
Modifier and Type | Method and Description |
---|---|
RpcOptionsBuilder |
RpcOptionsBuilder.deliverMode(DeliverOrder deliverOrder) |
RpcOptions |
RpcManagerImpl.getDefaultRpcOptions(boolean sync,
DeliverOrder deliverOrder) |
RpcOptions |
RpcManager.getDefaultRpcOptions(boolean sync,
DeliverOrder deliverOrder)
Creates a new
RpcOptionsBuilder . |
RpcOptionsBuilder |
RpcManagerImpl.getRpcOptionsBuilder(ResponseMode responseMode,
DeliverOrder deliverOrder) |
RpcOptionsBuilder |
RpcManager.getRpcOptionsBuilder(ResponseMode responseMode,
DeliverOrder deliverOrder)
Creates a new
RpcOptionsBuilder . |
Constructor and Description |
---|
RpcOptions(long timeout,
TimeUnit unit,
ResponseFilter responseFilter,
ResponseMode responseMode,
boolean skipReplicationQueue,
DeliverOrder deliverOrder) |
RpcOptionsBuilder(long timeout,
TimeUnit unit,
ResponseMode responseMode,
DeliverOrder deliverOrder) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
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) |
Modifier and Type | Method and Description |
---|---|
protected static org.jgroups.Message |
CommandAwareRpcDispatcher.constructMessage(org.jgroups.util.Buffer buf,
org.jgroups.Address recipient,
org.jgroups.blocks.ResponseMode mode,
boolean rsvp,
DeliverOrder deliverOrder) |
SingleResponseFuture |
CommandAwareRpcDispatcher.invokeRemoteCommand(org.jgroups.Address recipient,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
DeliverOrder deliverOrder) |
CompletableFuture<org.jgroups.util.RspList<Response>> |
CommandAwareRpcDispatcher.invokeRemoteCommands(List<org.jgroups.Address> recipients,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
org.jgroups.blocks.RspFilter filter,
DeliverOrder deliverOrder) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
RpcOptions |
ExtendedStatisticRpcManager.getDefaultRpcOptions(boolean sync,
DeliverOrder deliverOrder) |
RpcOptionsBuilder |
ExtendedStatisticRpcManager.getRpcOptionsBuilder(ResponseMode responseMode,
DeliverOrder deliverOrder) |
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.