org.wso2.carbon.analytics.dataservice.clustering

Class AnalyticsClusterManagerImpl

java.lang.Object

org.wso2.carbon.analytics.dataservice.clustering.AnalyticsClusterManagerImpl

All Implemented Interfaces:

com.hazelcast.core.MembershipListener, EventListener, AnalyticsClusterManager

public class AnalyticsClusterManagerImpl
extends Object
implements AnalyticsClusterManager, com.hazelcast.core.MembershipListener

This class represents an AnalyticsClusterManager implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AnalyticsClusterManagerImpl.LeaderUpdateNotification This class represents the cluster message that notifies the cluster of a new leader

Constructor Summary

Constructors

Constructor and Description
AnalyticsClusterManagerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
<T> List<T>	execute(String groupId, Callable<T> callable) Executes the given Callable in all the nodes in the group, including the current one.
Serializable	getProperty(String groupId, String name) Retrieves a property local to a given group.
boolean	isClusteringEnabled() Checks if the server is in clustered mode.
void	joinGroup(String groupId, GroupEventListener groupEventListener) Joins a given group.
void	memberAdded(com.hazelcast.core.MembershipEvent event)
void	memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent event)
void	memberRemoved(com.hazelcast.core.MembershipEvent event)
void	setProperty(String groupId, String name, Serializable value) Sets a property local to the given group.

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsClusterManagerImpl

public AnalyticsClusterManagerImpl()

Method Detail

joinGroup

public void joinGroup(String groupId,
             GroupEventListener groupEventListener)
               throws AnalyticsClusterException

Description copied from interface: AnalyticsClusterManager

Joins a given group.

Specified by:

joinGroup in interface AnalyticsClusterManager

Parameters:

groupId - The group id of the group

groupEventListener - The listener class to listen for group events

Throws:

AnalyticsClusterException

execute

public <T> List<T> execute(String groupId,
                  Callable<T> callable)
                throws AnalyticsClusterException

Description copied from interface: AnalyticsClusterManager

Executes the given Callable in all the nodes in the group, including the current one. This method executes even if clustering is not enabled, where then it will simply execute it in the current node and return a single response.

Specified by:

execute in interface AnalyticsClusterManager

Parameters:

groupId - The group id of the group

callable - The implementation to be executed

Returns:

The aggregation of results from all the nodes

Throws:

AnalyticsClusterException

setProperty

public void setProperty(String groupId,
               String name,
               Serializable value)

Description copied from interface: AnalyticsClusterManager

Sets a property local to the given group.

Specified by:

setProperty in interface AnalyticsClusterManager

Parameters:

groupId - The group id of the group

name - The name of the property

value - The property value

getProperty

public Serializable getProperty(String groupId,
                       String name)

Description copied from interface: AnalyticsClusterManager

Retrieves a property local to a given group.

Specified by:

getProperty in interface AnalyticsClusterManager

Parameters:

groupId - The group id of the group

name - THe name of the property

Returns:

The property value

isClusteringEnabled

public boolean isClusteringEnabled()

Description copied from interface: AnalyticsClusterManager

Checks if the server is in clustered mode.

Specified by:

isClusteringEnabled in interface AnalyticsClusterManager

Returns:

True if in clustered mode

memberAdded

public void memberAdded(com.hazelcast.core.MembershipEvent event)

Specified by:

memberAdded in interface com.hazelcast.core.MembershipListener

memberAttributeChanged

public void memberAttributeChanged(com.hazelcast.core.MemberAttributeEvent event)

Specified by:

memberAttributeChanged in interface com.hazelcast.core.MembershipListener

memberRemoved

public void memberRemoved(com.hazelcast.core.MembershipEvent event)

Specified by:

memberRemoved in interface com.hazelcast.core.MembershipListener