Modifier | Constructor and Description |
---|---|
protected |
AbstractDelegatingTransport(Transport actual) |
Modifier and Type | Method and Description |
---|---|
BackupResponse |
backupRemotely(Collection<XSiteBackup> backups,
ReplicableCommand rpcCommand) |
void |
checkTotalOrderSupported()
check if the transport has configured with total order deliver properties (has the sequencer in JGroups
protocol stack.
|
Address |
getAddress()
Retrieves the current cache instance's network address
|
Address |
getCoordinator() |
Log |
getLog() |
List<Address> |
getMembers()
Returns a list of members in the current cluster view.
|
List<Address> |
getPhysicalAddresses()
Retrieves the current cache instance's physical network addresses.
|
int |
getViewId() |
Map<Address,Response> |
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.
|
boolean |
isCoordinator() |
boolean |
isMulticastCapable()
Tests whether the transport supports true multicast
|
void |
start() |
void |
stop() |
protected final Transport actual
protected AbstractDelegatingTransport(Transport actual)
public Map<Address,Response> invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean totalOrder, boolean anycast) throws Exception
Transport
invokeRemotely
in interface Transport
recipients
- a list of Addresses to invoke the call on. If this is null, the call is broadcast to the
entire cluster.rpcCommand
- the cache command to invokemode
- the response mode to usetimeout
- a timeout after which to throw a replication exception.usePriorityQueue
- if true, a priority queue is used to deliver messages. May not be supported by all
implementations.responseFilter
- a response filter with which to filter out failed/unwanted/invalid responses.totalOrder
- the command will be send with total order propertiesanycast
- used when is true
, it means that it must use TOA instead of TOB.Exception
- in the event of problems.public BackupResponse backupRemotely(Collection<XSiteBackup> backups, ReplicableCommand rpcCommand) throws Exception
backupRemotely
in interface Transport
Exception
public boolean isCoordinator()
isCoordinator
in interface Transport
public Address getCoordinator()
getCoordinator
in interface Transport
public Address getAddress()
Transport
getAddress
in interface Transport
public List<Address> getPhysicalAddresses()
Transport
Transport.getAddress()
.getPhysicalAddresses
in interface Transport
public List<Address> getMembers()
Transport
getMembers
in interface Transport
public boolean isMulticastCapable()
Transport
isMulticastCapable
in interface Transport
public void start()
public void stop()
public void checkTotalOrderSupported()
Transport
checkTotalOrderSupported
in interface Transport
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.