java.lang.Object
- org.infinispan.remoting.rpc.RpcManagerImpl

All Implemented Interfaces:

JmxStatisticsExposer, org.infinispan.metrics.impl.CustomMetricsSupplier, RpcManager
```
@MBean(objectName="RpcManager",
       description="Manages all remote calls to remote cache instances in the cluster.")
public class RpcManagerImpl
extends Object
implements RpcManager, JmxStatisticsExposer, org.infinispan.metrics.impl.CustomMetricsSupplier
```
This component really is just a wrapper around a Transport implementation, and is used to set up the transport and provide lifecycle and dependency hooks into external transport implementations.

Since:

4.0

Author:

Manik Surtani, Galder Zamarreño, Mircea.Markus@jboss.com, Pedro Ruivo

Field Summary

Fields
Modifier and Type Field Description

static String OBJECT_NAME

Constructor Summary

Constructors
Constructor Description

RpcManagerImpl()

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`<T> T`	`blocking(CompletionStage<T> request)`	Block on a request and return its result.
`Address`	`getAddress()`	Returns the address associated with this RpcManager or null if not part of the cluster.
`long`	`getAverageReplicationTime()`
`long`	`getAverageXSiteReplicationTime()`
`long`	`getAverageXSiteReplicationTimeTo(String dstSite)`
`String`	`getCommittedViewAsString()`
`Collection<MBeanMetadata.AttributeMetadata>`	`getCustomMetrics()`
`long`	`getMaximumXSiteReplicationTime()`
`long`	`getMaximumXSiteReplicationTimeTo(String dstSite)`
`List<Address>`	`getMembers()`	Returns members of a cluster scoped to the cache owning this RpcManager.
`long`	`getMinimumXSiteReplicationTime()`
`long`	`getMinimumXSiteReplicationTimeTo(String dstSite)`
`long`	`getNumberXSiteRequests()`
`long`	`getNumberXSiteRequestsReceived()`
`long`	`getNumberXSiteRequestsReceivedFrom(String srcSite)`
`long`	`getNumberXSiteRequestsSentTo(String dstSite)`
`String`	`getPendingViewAsString()`
`long`	`getReplicationCount()`
`long`	`getReplicationFailures()`
`String`	`getSitesView()`
`boolean`	`getStatisticsEnabled()`	Returns whether an interceptor's statistics are being captured.
`String`	`getSuccessRatio()`
`double`	`getSuccessRatioFloatingPoint()`
`RpcOptions`	`getSyncRpcOptions()`
`int`	`getTopologyId()`	Returns the current topology id.
`Transport`	`getTransport()`
`<T> CompletionStage<T>`	`invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)`	Invoke a command on a collection of node and pass the responses to a `ResponseCollector`.
`<T> CompletionStage<T>`	`invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)`	Invoke a command on a single node and pass the response to a `ResponseCollector`.
`<T> CompletionStage<T>`	`invokeCommandOnAll(ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)`	Invoke a command on all the nodes in the cluster and pass the responses to a `ResponseCollector`.
`<T> CompletionStage<T>`	`invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)`	Invoke different commands on a collection of nodes and pass the responses to a `ResponseCollector`.
`<T> CompletionStage<T>`	`invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)`	Invoke a command on a collection of nodes and pass the responses to a `ResponseCollector`.
`CompletableFuture<Map<Address,Response>>`	`invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)`	Invokes a command on remote nodes.
`<O> XSiteResponse<O>`	`invokeXSite(org.infinispan.xsite.XSiteBackup backup, org.infinispan.xsite.XSiteReplicateCommand<O> command)`	Sends the `XSiteReplicateCommand` to a remote site.
`boolean`	`isStatisticsEnabled()`
`void`	`resetStatistics()`	Resets an interceptor's cache statistics
`void`	`sendTo(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)`	Asynchronously sends the `ReplicableCommand` to the destination using the specified `DeliverOrder`.
`void`	`sendToAll(ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)`	Asynchronously sends the `ReplicableCommand` to the entire cluster.
`void`	`sendToMany(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)`	Asynchronously sends the `ReplicableCommand` to the set of destination using the specified `DeliverOrder`.
`void`	`setCrossSiteReplicationTimes(TimerTracker timer)`
`void`	`setStatisticsEnabled(boolean statisticsEnabled)`	Deprecated. We already have an attribute, we shouldn't have an operation for the same thing.
`void`	`setTransport(Transport t)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.infinispan.remoting.rpc.RpcManager
getTotalSyncRpcOptions

Field Detail
- OBJECT_NAME
```
public static final String OBJECT_NAME
```
  See Also:
  
  Constant Field Values

Constructor Detail
- RpcManagerImpl
```
public RpcManagerImpl()
```

Method Detail

getCustomMetrics

public Collection<MBeanMetadata.AttributeMetadata> getCustomMetrics()

getCommittedViewAsString

@ManagedAttribute(description="Retrieves the committed view.",
                  displayName="Committed view",
                  dataType=TRAIT)
public String getCommittedViewAsString()