public interface Transport extends Lifecycle
Modifier and Type | Method and Description |
---|---|
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() |
void |
initialize(StreamingMarshaller marshaller,
ExecutorService asyncExecutor,
InboundInvocationHandler handler,
CacheManagerNotifier notifier)
Initializes the transport with global cache configuration and transport-specific properties.
|
Map<Address,Response> |
invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean supportReplay)
Invokes an RPC call on other caches in the cluster.
|
boolean |
isCoordinator() |
boolean |
isMulticastCapable()
Tests whether the transport supports true multicast
|
void |
setConfiguration(GlobalConfiguration gc) |
void |
start() |
void |
stop() |
void setConfiguration(GlobalConfiguration gc)
void initialize(StreamingMarshaller marshaller, ExecutorService asyncExecutor, InboundInvocationHandler handler, CacheManagerNotifier notifier)
marshaller
- marshaller to use for marshalling and unmarshallingasyncExecutor
- executor to use for asynchronous callshandler
- handler for invoking remotely originating calls on the local cachenotifier
- notifier to useMap<Address,Response> invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean supportReplay) 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.supportReplay
- whether replays of missed messages is supportedException
- in the event of problems.boolean isCoordinator()
Address getCoordinator()
Address getAddress()
List<Address> getPhysicalAddresses()
getAddress()
.List<Address> getMembers()
boolean isMulticastCapable()
int getViewId()
CacheException
- if the transport has been stopped.Log getLog()
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.