lumis.portal.cluster

Class AbstractClusterManager

java.lang.Object

lumis.portal.cluster.AbstractClusterManager

All Implemented Interfaces:

IClusterManager

Direct Known Subclasses:

JGroupsClusterManager, SingleServerClusterManager

public abstract class AbstractClusterManager
extends Object
implements IClusterManager

Generic implementation for IClusterManager, independent of communication form.

Since:

4.0.0

Version:

$Revision: 17474 $ $Date: 2015-06-30 23:44:13 +0000 (Tue, 30 Jun 2015) $

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	processTransmissionsReceived Indicates whether transmissionReceived(IClusterTransmission) processes the given transmission.
protected String	serverId The identifier for this cluster node.

Constructor Summary

Constructors

Constructor and Description
AbstractClusterManager()

Method Summary

Modifier and Type	Method and Description
<T extends Serializable> IClusterCommand<T>	createClusterCommand(IClusterCallable<T> callable) Creates a cluster command instance and returns it.
IClusterCommand<Serializable>	createClusterCommand(Runnable runnable) Creates a cluster command instance and returns it.
IClusterMessage	createClusterMessage(String group, Serializable data) Creates a cluster message instance and returns it.
void	destroy() Destroys the cluster manager.
void	init() Initializes the cluster manager.
protected <T extends Serializable> ITransmissionResult<T>	transmissionReceived(IClusterTransmission transmission) Processes a received transmission.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface lumis.portal.cluster.IClusterManager

call, getClusterConfig, getLocalMember, getMembers, send

Field Detail

serverId

protected String serverId

The identifier for this cluster node.

Since:

4.1.0

processTransmissionsReceived

protected boolean processTransmissionsReceived

Indicates whether transmissionReceived(IClusterTransmission) processes the given transmission.

Since:

4.1.0

Constructor Detail

AbstractClusterManager

public AbstractClusterManager()

Method Detail

transmissionReceived

protected <T extends Serializable> ITransmissionResult<T> transmissionReceived(IClusterTransmission transmission)

Processes a received transmission. Subclasses should call this method whenever a transmission is received. processTransmissionsReceived may be used to disable the processing done by this method.

Parameters:

transmission - the transmission received.

Since:

4.1.0

init

public void init()

Description copied from interface: IClusterManager

Initializes the cluster manager. This method should start the monitoring and connections necessary for the cluster manager to execute its communications.

Specified by:

init in interface IClusterManager

destroy

public void destroy()

Description copied from interface: IClusterManager

Destroys the cluster manager. This method should close all resources used by the cluster manager.

Specified by:

destroy in interface IClusterManager

createClusterCommand

public IClusterCommand<Serializable> createClusterCommand(Runnable runnable)

Description copied from interface: IClusterManager

Creates a cluster command instance and returns it.

Specified by:

createClusterCommand in interface IClusterManager

Parameters:

runnable - the runnable that contains the command's execution. It must be serializable.

See Also:

IClusterCommand

createClusterCommand

public <T extends Serializable> IClusterCommand<T> createClusterCommand(IClusterCallable<T> callable)

Description copied from interface: IClusterManager

Creates a cluster command instance and returns it.

Specified by:

createClusterCommand in interface IClusterManager

Parameters:

callable - the IClusterCallable that contains the command's execution. It must be serializable.

Returns:

the created cluster command.

createClusterMessage

public IClusterMessage createClusterMessage(String group,
                                            Serializable data)

Description copied from interface: IClusterManager

Creates a cluster message instance and returns it.

Specified by:

createClusterMessage in interface IClusterManager

Parameters:

group - the destination group for the message.

data - the data sent in the message.

Returns:

the cluster message created.

See Also:

IClusterMessage