|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Response | |
---|---|
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. |
Uses of Response in org.infinispan.remoting |
---|
Methods in org.infinispan.remoting that return Response | |
---|---|
Response |
InboundInvocationHandlerImpl.handle(CacheRpcCommand cmd,
Address origin)
|
Response |
InboundInvocationHandler.handle(CacheRpcCommand command,
Address origin)
Invokes a command on the cache, from a remote source. |
Uses of Response in org.infinispan.remoting.responses |
---|
Classes in org.infinispan.remoting.responses that implement Response | |
---|---|
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 |
Methods in org.infinispan.remoting.responses that return Response | |
---|---|
Response |
ResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue)
|
Response |
DistributionResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue)
|
Response |
DefaultResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue)
|
protected Response |
NoReturnValuesDistributionResponseGenerator.handleWriteCommand(WriteCommand wc,
Object returnValue)
|
protected Response |
DistributionResponseGenerator.handleWriteCommand(WriteCommand wc,
Object returnValue)
|
Methods in org.infinispan.remoting.responses with parameters of type Response | |
---|---|
boolean |
IgnoreExtraResponsesValidityFilter.isAcceptable(Response response,
Address address)
|
boolean |
ClusteredGetResponseValidityFilter.isAcceptable(Response response,
Address address)
|
Uses of Response in org.infinispan.remoting.rpc |
---|
Methods in org.infinispan.remoting.rpc that return types with arguments of type Response | |
---|---|
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. |
Methods in org.infinispan.remoting.rpc with parameters of type Response | |
---|---|
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 |
Uses of Response in org.infinispan.remoting.transport |
---|
Methods in org.infinispan.remoting.transport that return types with arguments of type Response | |
---|---|
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. |
Method parameters in org.infinispan.remoting.transport with type arguments of type Response | |
---|---|
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
Throwable exception,
Map<Address,Response> responseListToAddTo,
boolean wasSuspected,
boolean wasReceived,
Address sender,
boolean usedResponseFilter,
boolean ignoreLeavers)
|
Uses of Response in org.infinispan.remoting.transport.jgroups |
---|
Methods in org.infinispan.remoting.transport.jgroups that return Response | |
---|---|
Response |
CommandAwareRpcDispatcher.invokeRemoteCommand(org.jgroups.Address recipient,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean oob,
boolean asyncMarshalling)
|
Methods in org.infinispan.remoting.transport.jgroups that return types with arguments of type Response | |
---|---|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
|
Uses of Response in org.infinispan.transaction |
---|
Methods in org.infinispan.transaction with parameters of type Response | |
---|---|
static void |
WriteSkewHelper.readVersionsFromResponse(Response r,
CacheTransaction ct)
|
Uses of Response in org.infinispan.util.logging |
---|
Method parameters in org.infinispan.util.logging with type arguments of type Response | |
---|---|
void |
Log.expectedJustOneResponse(Map<Address,Response> lr)
|
void |
Log.unknownResponsesFromRemoteCache(Collection<Response> responses)
|
|
--> |