|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Transport
An interface that provides a communication link with remote caches. Also allows remote caches to invoke commands on this cache instance.
Method Summary | |
---|---|
BackupResponse |
backupRemotely(Collection<XSiteBackup> backups,
ReplicableCommand rpcCommand)
|
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)
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()
|
Method Detail |
---|
Map<Address,Response> invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter) throws Exception
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.
Exception
- in the event of problems.BackupResponse backupRemotely(Collection<XSiteBackup> backups, ReplicableCommand rpcCommand) throws Exception
Exception
boolean isCoordinator()
Address getCoordinator()
Address getAddress()
List<Address> getPhysicalAddresses()
getAddress()
.
List<Address> getMembers()
boolean isMulticastCapable()
void start()
start
in interface Lifecycle
void stop()
stop
in interface Lifecycle
int getViewId()
CacheException
- if the transport has been stopped.Log getLog()
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |