Package | Description |
---|---|
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.distribution | |
org.infinispan.remoting |
Remote communication between cache instances.
|
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.
|
org.infinispan.transaction |
JTA transaction support.
|
org.infinispan.util.logging |
Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ReplicationInterceptor.checkTxCommandResponses(Map<Address,Response> responseMap,
TransactionBoundaryCommand command) |
Modifier and Type | Method and Description |
---|---|
protected void |
TxDistributionInterceptor.checkTxCommandResponses(Map<Address,Response> responseMap,
TransactionBoundaryCommand command) |
protected Object |
NonTxConcurrentDistributionInterceptor.getResponseFromPrimaryOwner(Address primaryOwner,
Map<Address,Response> addressResponseMap) |
protected Object |
NonTxDistributionInterceptor.getResponseFromPrimaryOwner(Address primaryOwner,
Map<Address,Response> addressResponseMap) |
Modifier and Type | Method and Description |
---|---|
Response |
InboundInvocationHandlerImpl.handle(CacheRpcCommand cmd,
Address origin) |
Response |
InboundInvocationHandler.handle(CacheRpcCommand command,
Address origin)
Invokes a command on the cache, from a remote source.
|
Modifier and Type | Class and Description |
---|---|
class |
CacheNotFoundResponse
A response that signals the named cache is not running on the target node.
|
class |
ExceptionResponse
A response that encapsulates an exception
|
class |
InvalidResponse
An invalid response
|
class |
SuccessfulResponse
A successful response
|
class |
UnsuccessfulResponse
An unsuccessful response
|
class |
UnsureResponse
An unsure response - used with Dist - essentially asks the caller to check the next response from the next node since
the sender is in a state of flux (probably in the middle of rebalancing)
|
class |
ValidResponse
A valid response
|
Modifier and Type | Method and Description |
---|---|
Response |
DefaultResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
DistributionResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
ResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
protected Response |
NoReturnValuesDistributionResponseGenerator.handleWriteCommand(WriteCommand wc,
Object returnValue) |
protected Response |
DistributionResponseGenerator.handleWriteCommand(WriteCommand wc,
Object returnValue) |
Modifier and Type | Method and Description |
---|---|
boolean |
IgnoreExtraResponsesValidityFilter.isAcceptable(Response response,
Address address) |
boolean |
ClusteredGetResponseValidityFilter.isAcceptable(Response response,
Address address) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync)
Broadcasts an RPC command to a specified set of recipients
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue,
long timeout) |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue) |
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster.
|
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)
Invokes an RPC call on other caches in the cluster.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ResponseFilter.isAcceptable(Response response,
Address sender)
Determines whether a response from a given sender should be added to the response list of the request
|
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
Throwable exception,
Map<Address,Response> responseListToAddTo,
boolean wasSuspected,
boolean wasReceived,
Address sender,
boolean usedResponseFilter,
boolean ignoreLeavers) |
Modifier and Type | Method and Description |
---|---|
Response |
CommandAwareRpcDispatcher.invokeRemoteCommand(org.jgroups.Address recipient,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean oob,
boolean asyncMarshalling) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter) |
Modifier and Type | Method and Description |
---|---|
static void |
WriteSkewHelper.readVersionsFromResponse(Response r,
CacheTransaction ct) |
Modifier and Type | Method and Description |
---|---|
void |
Log.expectedJustOneResponse(Map<Address,Response> lr) |
void |
Log.unknownResponsesFromRemoteCache(Collection<Response> responses) |
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.