lumis.portal.cluster

Interface IClusterManager

All Known Implementing Classes:

AbstractClusterManager, JGroupsClusterManager, SingleServerClusterManager

@StableMinor(version="12.0",
             sinceVersion="4.1")
public interface IClusterManager

Provides operations on the portal cluster.

A message may be sent by creating it using createClusterMessage(String, Serializable) and sending the IClusterMessage object returned by calling send(IClusterTransmission). When received, the message generates a ClusterMessageReceivedEvent.

A command may be sent by creating it using createClusterCommand(Runnable) and sending the IClusterCommand object returned by calling send(IClusterTransmission). When received, the command executes the corresponding Runnable code.

Either the message or the command, can be further configured before sending by using the available methods in the returned object.

Since:

4.0.0

Version:

$Revision: 23034 $ $Date: 2019-08-05 19:52:47 +0000 (Mon, 05 Aug 2019) $

See Also:

IClusterMessage, IClusterCommand

Method Summary

Modifier and Type	Method and Description
<T extends Serializable> T	call(IClusterCommand<T> command) Calls a cluster command execution and returns the result of the local execution.
<T extends Serializable> IClusterCommand<T>	createClusterCommand(IClusterCallable<T> callable) Creates a cluster command instance and returns it.
IClusterCommand<Serializable>	createClusterCommand(Runnable runnable) Deprecated. since 8.0.0 replaced by createClusterCommand(IClusterCallable).
IClusterMessage	createClusterMessage(String group, Serializable data) Creates a cluster message instance and returns it.
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.
void	send(IClusterTransmission transmission) Sends a transmission.

Method Detail

init

void init()

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

destroy

void destroy()

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

send

void send(IClusterTransmission transmission)

Sends a transmission.

Parameters:

transmission - the transmission. It must have been created using one of the factory methods available in IClusterManager.

See Also:

createClusterCommand(IClusterCallable), createClusterMessage(String, Serializable)

call

<T extends Serializable> T call(IClusterCommand<T> command)
                         throws Exception

Calls a cluster command execution and returns the result of the local execution.

This method sends the command through the cluster and gives feedback on the local server execution, in the form of the return value and the raised exception.

It is important to notice that the command will be sent over the cluster despite its execution outcome.

The given command must have been created through createClusterCommand(IClusterCallable).

Parameters:

command - the command to execute through the cluster.

Returns:

the command execution outcome.

Throws:

Exception - the exception thrown during command execution or other unknown exception.

Since:

8.0.0

getMembers

Collection<IClusterMember> getMembers()
                               throws PortalException

Returns a collection with information about the current members of this cluster.

Returns:

a collection with information about the current members of this cluster.

Throws:

PortalException

Since:

4.0.11

getLocalMember

IClusterMember getLocalMember()

Returns the current cluster member object. The object returned represents the member where this method is executed on.

Returns:

this server cluster member object.

Since:

4.2.0

createClusterMessage

IClusterMessage createClusterMessage(String group,
                                     Serializable data)

Creates a cluster message instance and returns it.

Parameters:

group - the destination group for the message.

data - the data sent in the message.

Returns:

the cluster message created.

Since:

4.1.0

See Also:

IClusterMessage

createClusterCommand

@Deprecated
IClusterCommand<Serializable> createClusterCommand(Runnable runnable)

Deprecated. since 8.0.0 replaced by createClusterCommand(IClusterCallable).

Creates a cluster command instance and returns it.

Parameters:

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

Since:

4.1.0

See Also:

IClusterCommand

createClusterCommand

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

Creates a cluster command instance and returns it.

Parameters:

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

Returns:

the created cluster command.

Since:

8.0.0

getClusterConfig

IClusterConfig getClusterConfig(ITransaction transaction)
                         throws PortalException

Returns a persistent cluster configuration object. The object contains the cluster configurations, and any changes will be applied on transaction commit.

Parameters:

transaction - the transaction for persistence access.

Returns:

a persistent cluster configuration instance.

Throws:

PortalException

Since:

4.1.0