com.haulmont.cuba.core.app

Class ClusterManager

java.lang.Object

com.haulmont.cuba.core.app.ClusterManager

All Implemented Interfaces:

ClusterManagerAPI

Direct Known Subclasses:

TestClusterManager

@Component(value="cuba_ClusterManager")
public class ClusterManager
extends java.lang.Object
implements ClusterManagerAPI

Standard implementation of middleware clustering based on JGroups.

Field Summary

Fields inherited from interface com.haulmont.cuba.core.app.ClusterManagerAPI

NAME

Constructor Summary

Constructors

Constructor and Description
ClusterManager()

Method Summary

Modifier and Type	Method and Description
void	addListener(java.lang.Class messageClass, ClusterListener listener) Subscribe to messages from other cluster nodes.
int	getActiveThreadsCount()
org.jgroups.JChannel	getChannel()
java.lang.String	getCurrentView() Return a string representation of a set of active nodes in the cluster.
int	getMessagesCount()
long	getReceivedBytes(java.lang.String className) Get received bytes for specified className
long	getReceivedMessages(java.lang.String className) Get received messages count for specified className
long	getSentBytes(java.lang.String className) Get sent bytes for specified className
long	getSentMessages(java.lang.String className) Get sent messages count for specified className
boolean	getSyncSendingForCurrentThread()
boolean	isMaster() Inform whether the current node is currently the master node in the cluster.
boolean	isStarted()
java.lang.String	printMessagesStat() Sent/received messages statistics
java.lang.String	printSharedStateStat() Shared state statistics
void	removeListener(java.lang.Class messageClass, ClusterListener listener) Unsubscribe from messages from other cluster nodes.
void	send(java.io.Serializable message) Send a message to all active cluster nodes.
void	sendSync(java.io.Serializable message) Send a message to all active cluster nodes synchronously.
void	setSyncSendingForCurrentThread(boolean sync) Forces synchronous sending for the current thread.
void	start() Join a cluster.
void	stop() Leave the cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterManager

public ClusterManager()

Method Detail

getChannel

public org.jgroups.JChannel getChannel()

send

public void send(java.io.Serializable message)

Description copied from interface: ClusterManagerAPI

Send a message to all active cluster nodes.

Specified by:

send in interface ClusterManagerAPI

Parameters:

message - serializable message

sendSync

public void sendSync(java.io.Serializable message)

Description copied from interface: ClusterManagerAPI

Send a message to all active cluster nodes synchronously.

Specified by:

sendSync in interface ClusterManagerAPI

Parameters:

message - serializable message

getSyncSendingForCurrentThread

public boolean getSyncSendingForCurrentThread()

Specified by:

getSyncSendingForCurrentThread in interface ClusterManagerAPI

Returns:

whether the synchronous sending is forced for the current thread

See Also:

ClusterManagerAPI.setSyncSendingForCurrentThread(boolean)

setSyncSendingForCurrentThread

public void setSyncSendingForCurrentThread(boolean sync)

Description copied from interface: ClusterManagerAPI

Forces synchronous sending for the current thread. It means that the ClusterManagerAPI.send(Serializable) method will send the message in the current thread and block until returning from the clustering implementation.

Specified by:

setSyncSendingForCurrentThread in interface ClusterManagerAPI

Parameters:

sync - true to force synchronous sending

addListener

public void addListener(java.lang.Class messageClass,
                        ClusterListener listener)

Description copied from interface: ClusterManagerAPI

Subscribe to messages from other cluster nodes.

Specified by:

addListener in interface ClusterManagerAPI

Parameters:

messageClass - the class of messages we want to be notified

listener - listener instance

removeListener

public void removeListener(java.lang.Class messageClass,
                           ClusterListener listener)

Description copied from interface: ClusterManagerAPI

Unsubscribe from messages from other cluster nodes.

Specified by:

removeListener in interface ClusterManagerAPI

Parameters:

messageClass - the class of messages we don't want to be notified anymore

listener - listener instance

start

public void start()

Description copied from interface: ClusterManagerAPI

Join a cluster.

Specified by:

start in interface ClusterManagerAPI

getActiveThreadsCount

public int getActiveThreadsCount()

Specified by:

getActiveThreadsCount in interface ClusterManagerAPI

Returns:

threads count that are actively sending cluster messages

getMessagesCount

public int getMessagesCount()

Specified by:

getMessagesCount in interface ClusterManagerAPI

Returns:

cluster messages count queued to send

stop

public void stop()

Description copied from interface: ClusterManagerAPI

Leave the cluster.

Specified by:

stop in interface ClusterManagerAPI

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ClusterManagerAPI

Returns:

true if clustering is started on this node

isMaster

public boolean isMaster()

Description copied from interface: ClusterManagerAPI

Inform whether the current node is currently the master node in the cluster. A middleware cluster always elects one of its members as master, ususally it is the oldest one.

Specified by:

isMaster in interface ClusterManagerAPI

Returns:

true if the current node is the master

getCurrentView

public java.lang.String getCurrentView()

Description copied from interface: ClusterManagerAPI

Return a string representation of a set of active nodes in the cluster. This string depends on clustering implementation and should not be parsed or otherwise analyzed in the application.

Specified by:

getCurrentView in interface ClusterManagerAPI

Returns:

string representation of a set of active nodes

printSharedStateStat

public java.lang.String printSharedStateStat()

Description copied from interface: ClusterManagerAPI

Shared state statistics

Specified by:

printSharedStateStat in interface ClusterManagerAPI

Returns:

statistics

printMessagesStat

public java.lang.String printMessagesStat()

Description copied from interface: ClusterManagerAPI

Sent/received messages statistics

Specified by:

printMessagesStat in interface ClusterManagerAPI

Returns:

statistics

getSentMessages

public long getSentMessages(java.lang.String className)

Description copied from interface: ClusterManagerAPI

Get sent messages count for specified className

Specified by:

getSentMessages in interface ClusterManagerAPI

Returns:

messages count

getSentBytes

public long getSentBytes(java.lang.String className)

Description copied from interface: ClusterManagerAPI

Get sent bytes for specified className

Specified by:

getSentBytes in interface ClusterManagerAPI

Returns:

size in bytes

getReceivedMessages

public long getReceivedMessages(java.lang.String className)

Description copied from interface: ClusterManagerAPI

Get received messages count for specified className

Specified by:

getReceivedMessages in interface ClusterManagerAPI

Returns:

messages count

getReceivedBytes

public long getReceivedBytes(java.lang.String className)

Description copied from interface: ClusterManagerAPI

Get received bytes for specified className

Specified by:

getReceivedBytes in interface ClusterManagerAPI

Returns:

size in bytes