All Known Implementing Classes:

AbstractClusterManager, JGroupsClusterManager, SingleServerClusterManager
```
@StableMinor(version="14.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: 24477 $ $Date: 2021-04-28 11:30:36 -0300 (Wed, 28 Apr 2021) $

See Also:

IClusterMessage, IClusterCommand

Method Summary

All Methods Instance Methods Abstract Methods Deprecated Methods
Modifier and Type	Method	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> Map<IClusterMember,T>`	`callAndWaitResponses(IClusterCallable<T> command, long timeout)`	Calls a cluster command execution and waits all current cluster servers to respond with their result and, then, returns an unmodifiable map having the cluster member as the key and the execution result as the value.
`IClusterCommand<Serializable>`	`createClusterCommand(Runnable runnable)`	Deprecated. since 8.0.0 replaced by `createClusterCommand(IClusterCallable)`.
`<T extends Serializable> IClusterCommand<T>`	`createClusterCommand(IClusterCallable<T> callable)`	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.
`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
  - callAndWaitResponses
```
<T extends Serializable> Map<IClusterMember,T> callAndWaitResponses(IClusterCallable<T> command,
                                                                          long timeout)
                                                                   throws ClusterInvocationException,
                                                                          TimeoutException,
                                                                          InterruptedException,
                                                                          IllegalArgumentException
```
    Calls a cluster command execution and waits all current cluster servers to respond with their result and, then, returns an unmodifiable map having the cluster member as the key and the execution result as the value.
    If some server raises an exception, a ClusterInvocationException will be raised locally on the server that called this method with all exceptions that happened in the servers as suppressed.
    
    This method has no guarantee it will execute properly if cluster members enter or leave the cluster during its execution.
    
    If all responses couldn't be retrieved in the given timeout, a TimeoutException will be raised.
    
    The given command must have been created through createClusterCommand(IClusterCallable).
    
    Type Parameters:
    
    T - the response type. it must be serializable.
    
    Parameters:
    
    command - the command to be invoked.
    
    timeout - the timeout this method will wait the invoke finishes.
    
    Returns:
    
    a map with all responses.
    
    Throws:
    
    ClusterInvocationException - if some server raises an exception during the invoke.
    
    TimeoutException - if the timeout has been reached and not all responses were returned.
    
    InterruptedException - if the thread that called this method was interrupted.
    
    IllegalArgumentException - if the given command is null.
    
    IllegalArgumentException - if the given timeout is not a positive number.
    
    Since:
    
    12.1.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

Interface IClusterManager

Method Summary

Method Detail

init

destroy

send

call

callAndWaitResponses

getMembers

getLocalMember

createClusterMessage

createClusterCommand

createClusterCommand

getClusterConfig