|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.remoting.transport.jgroups.JGroupsTransport
public class JGroupsTransport
An encapsulation of a JGroups transport
Field Summary | |
---|---|
static String |
CONFIGURATION_FILE
|
static String |
CONFIGURATION_STRING
|
static String |
CONFIGURATION_XML
|
Constructor Summary | |
---|---|
JGroupsTransport()
|
Method Summary | |
---|---|
void |
block()
|
Address |
getAddress()
Retrieves the current cache instance's network address |
Address |
getCoordinator()
|
DistributedSync |
getDistributedSync()
|
List<Address> |
getMembers()
Returns a list of members in the current cluster view. |
byte[] |
getState()
|
void |
getState(OutputStream ostream)
|
byte[] |
getState(String state_id)
|
void |
getState(String cacheName,
OutputStream ostream)
|
void |
initialize(GlobalConfiguration c,
Marshaller marshaller,
ExecutorService asyncExecutor,
InboundInvocationHandler inboundInvocationHandler,
CacheManagerNotifier notifier)
Initializes the transport with global cache configuration and transport-specific properties. |
List<Response> |
invokeRemotely(List<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 |
isSupportStateTransfer()
Tests whether the transport supports state transfer |
void |
receive(org.jgroups.Message msg)
|
boolean |
retrieveState(String cacheName,
Address address,
long timeout)
Initiates a state retrieval from a specific cache (by typically invoking InboundInvocationHandler.generateState(String, java.io.OutputStream) ), and applies this
state to the current cache via the InboundInvocationHandler.applyState(String, java.io.InputStream)
callback. |
void |
setState(byte[] state)
|
void |
setState(InputStream istream)
|
void |
setState(String state_id,
byte[] state)
|
void |
setState(String cacheName,
InputStream istream)
|
void |
start()
|
void |
stop()
|
void |
suspect(org.jgroups.Address suspected_mbr)
|
void |
unblock()
|
void |
viewAccepted(org.jgroups.View newView)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String CONFIGURATION_STRING
public static final String CONFIGURATION_XML
public static final String CONFIGURATION_FILE
Constructor Detail |
---|
public JGroupsTransport()
Method Detail |
---|
public void initialize(GlobalConfiguration c, Marshaller marshaller, ExecutorService asyncExecutor, InboundInvocationHandler inboundInvocationHandler, CacheManagerNotifier notifier)
Transport
initialize
in interface Transport
c
- global cache-wide configurationmarshaller
- marshaller to use for marshalling and unmarshallingasyncExecutor
- executor to use for asynchronous callsinboundInvocationHandler
- handler for invoking remotely originating calls on the local cachenotifier
- notifier to usepublic void start()
start
in interface Lifecycle
start
in interface Transport
public void stop()
stop
in interface Lifecycle
stop
in interface Transport
public boolean isCoordinator()
isCoordinator
in interface Transport
public Address getCoordinator()
getCoordinator
in interface Transport
public List<Address> getMembers()
Transport
getMembers
in interface Transport
public boolean retrieveState(String cacheName, Address address, long timeout) throws StateTransferException
Transport
InboundInvocationHandler.generateState(String, java.io.OutputStream)
), and applies this
state to the current cache via the InboundInvocationHandler.applyState(String, java.io.InputStream)
callback.
retrieveState
in interface Transport
cacheName
- name of cache for which to retrieve stateaddress
- address of remote cache from which to retrieve statetimeout
- state retrieval timeout in milliseconds
StateTransferException
- if state cannot be retrieved from the specific cachepublic DistributedSync getDistributedSync()
getDistributedSync
in interface Transport
public boolean isSupportStateTransfer()
Transport
isSupportStateTransfer
in interface Transport
public Address getAddress()
Transport
getAddress
in interface Transport
public List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean supportReplay) 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.supportReplay
- whether replays of missed messages is supported
Exception
- in the event of problems.public void viewAccepted(org.jgroups.View newView)
viewAccepted
in interface org.jgroups.MembershipListener
public void suspect(org.jgroups.Address suspected_mbr)
suspect
in interface org.jgroups.MembershipListener
public void block()
block
in interface org.jgroups.MembershipListener
public void unblock()
unblock
in interface org.jgroups.ExtendedMembershipListener
public void receive(org.jgroups.Message msg)
receive
in interface org.jgroups.MessageListener
public byte[] getState()
getState
in interface org.jgroups.MessageListener
public void setState(byte[] state)
setState
in interface org.jgroups.MessageListener
public byte[] getState(String state_id)
getState
in interface org.jgroups.ExtendedMessageListener
public void setState(String state_id, byte[] state)
setState
in interface org.jgroups.ExtendedMessageListener
public void getState(OutputStream ostream)
getState
in interface org.jgroups.ExtendedMessageListener
public void getState(String cacheName, OutputStream ostream)
getState
in interface org.jgroups.ExtendedMessageListener
public void setState(InputStream istream)
setState
in interface org.jgroups.ExtendedMessageListener
public void setState(String cacheName, InputStream istream)
setState
in interface org.jgroups.ExtendedMessageListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |