|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object lumis.portal.cluster.AbstractClusterManager lumis.portal.cluster.multiserver.JGroupsClusterManager
public class JGroupsClusterManager
A ClusterManager that uses the JGroups library for communication between the cluster nodes.
Field Summary |
---|
Fields inherited from class lumis.portal.cluster.AbstractClusterManager |
---|
processTransmissionsReceived, serverId |
Constructor Summary | |
---|---|
JGroupsClusterManager()
|
Method Summary | |
---|---|
void |
destroy()
Destroys the cluster manager. |
IClusterConfig |
getClusterConfig(ITransaction transaction)
Returns a persistent cluster configuration object. |
IClusterMember |
getLocalMember()
Returns the current cluster member object. |
Collection<IClusterMember> |
getMembers()
Returns a collection with information about the current members of this cluster. |
void |
init()
Initializes the cluster manager. |
long |
processAllPendingMessages(long lastTransmissionOrder)
Processes all pending messages in the database. |
void |
processMessage(org.jgroups.Message message)
Processes a message. |
void |
send(IClusterTransmission transmission)
Sends a transmission. |
protected void |
transmissionReceived(IClusterTransmission transmission)
Processes a received transmission. |
void |
updateAck(long transmissionOrder)
Updates the acknowledgment persisted as the specified last transmission order. |
Methods inherited from class lumis.portal.cluster.AbstractClusterManager |
---|
createClusterCommand, createClusterMessage |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JGroupsClusterManager()
Method Detail |
---|
public void init()
IClusterManager
init
in interface IClusterManager
init
in class AbstractClusterManager
public void destroy()
IClusterManager
destroy
in interface IClusterManager
destroy
in class AbstractClusterManager
protected void transmissionReceived(IClusterTransmission transmission)
AbstractClusterManager
AbstractClusterManager.processTransmissionsReceived
may be used to disable the processing done by this method.
transmissionReceived
in class AbstractClusterManager
transmission
- the transmission received.public void send(IClusterTransmission transmission)
IClusterManager
send
in interface IClusterManager
send
in class AbstractClusterManager
transmission
- the transmission. It must have been created using
one of the factory methods available in IClusterManager
.IClusterManager.createClusterCommand(Runnable)
,
IClusterManager.createClusterMessage(String, Serializable)
public Collection<IClusterMember> getMembers()
IClusterManager
getMembers
in interface IClusterManager
public IClusterMember getLocalMember()
IClusterManager
getLocalMember
in interface IClusterManager
public IClusterConfig getClusterConfig(ITransaction transaction) throws PortalException
IClusterManager
getClusterConfig
in interface IClusterManager
transaction
- the transaction for persistence access.
PortalException
public long processAllPendingMessages(long lastTransmissionOrder)
MessageReceiver.IProcessMessageCallback
processAllPendingMessages
in interface MessageReceiver.IProcessMessageCallback
lastTransmissionOrder
- TODO
public void processMessage(org.jgroups.Message message)
MessageReceiver.IProcessMessageCallback
processMessage
in interface MessageReceiver.IProcessMessageCallback
message
- the message.public void updateAck(long transmissionOrder)
MessageReceiver.IProcessMessageCallback
updateAck
in interface MessageReceiver.IProcessMessageCallback
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |