Package | Description |
---|---|
org.infinispan.interceptors.base |
Base interceptors containing common, reusable behavior.
|
org.infinispan.remoting.responses |
Abstractions of the different response types allowed during RPC.
|
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 |
---|---|
protected ResponseFilter |
BaseRpcInterceptor.getIgnoreExtraResponseFilter(Collection<Address> recipients) |
protected ResponseFilter |
BaseRpcInterceptor.getSelfDeliverFilter() |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
BaseRpcInterceptor.totalOrderAnycastPrepare(Collection<Address> recipients,
PrepareCommand prepareCommand,
ResponseFilter responseFilter) |
protected Map<Address,Response> |
BaseRpcInterceptor.totalOrderBroadcastPrepare(PrepareCommand prepareCommand,
ResponseFilter responseFilter) |
Modifier and Type | Class and Description |
---|---|
class |
ClusteredGetResponseValidityFilter
A filter that tests the validity of
ClusteredGetCommand s. |
class |
IgnoreExtraResponsesValidityFilter
A filter that only expects responses from an initial set of targets.
|
class |
KeysValidateFilter
Used in Total Order based commit protocol in Distributed Mode
This filter awaits for one valid response for each key to be validated.
|
class |
SelfDeliverFilter
Used in Total Order based protocol.
|
Modifier and Type | Method and Description |
---|---|
ResponseFilter |
RpcOptions.responseFilter() |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Deprecated.
this method may be removed in the future. Use
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) |
RpcOptionsBuilder |
RpcOptionsBuilder.responseFilter(ResponseFilter responseFilter)
Sets the
ResponseFilter . |
Constructor and Description |
---|
RpcOptions(long timeout,
TimeUnit unit,
ResponseFilter responseFilter,
ResponseMode responseMode,
boolean skipReplicationQueue,
boolean fifoOrder,
boolean totalOrder) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Constructor and Description |
---|
JGroupsResponseFilterAdapter(ResponseFilter r)
Creates an instance of the adapter
|
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.