org.apache.unomi.services.impl.cluster

Class ClusterServiceImpl

java.lang.Object

org.apache.unomi.services.impl.cluster.ClusterServiceImpl

All Implemented Interfaces:

org.apache.unomi.api.services.ClusterService

public class ClusterServiceImpl
extends Object
implements org.apache.unomi.api.services.ClusterService

Implementation of the persistence service interface

Field Summary

Fields

Modifier and Type	Field and Description
static String	KARAF_CELLAR_CLUSTER_NODE_CONFIGURATION
static String	KARAF_CLUSTER_CONFIGURATION_INTERNAL_ENDPOINTS
static String	KARAF_CLUSTER_CONFIGURATION_PUBLIC_ENDPOINTS

Constructor Summary

Constructors

Constructor and Description
ClusterServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	destroy()
List<org.apache.unomi.api.ClusterNode>	getClusterNodes()
Map<String,Map<String,Serializable>>	getNodeSystemStatistics()
void	init()
boolean	isClusterConfigPIDAllowed(org.apache.karaf.cellar.core.Group group, String category, String pid, org.apache.karaf.cellar.core.event.EventType type) Check if a configuration is allowed.
void	purge(Date date)
void	purge(String scope)
void	sendEvent(Serializable eventObject)
void	setInternalAddress(String internalAddress)
void	setKarafCellarClusterManager(org.apache.karaf.cellar.core.ClusterManager karafCellarClusterManager)
void	setKarafCellarEventProducer(org.apache.karaf.cellar.core.event.EventProducer karafCellarEventProducer)
void	setKarafCellarGroupManager(org.apache.karaf.cellar.core.GroupManager karafCellarGroupManager)
void	setKarafCellarGroupName(String karafCellarGroupName)
void	setNodeStatisticsUpdateFrequency(long nodeStatisticsUpdateFrequency)
void	setOsgiConfigurationAdmin(org.osgi.service.cm.ConfigurationAdmin osgiConfigurationAdmin)
void	setPersistenceService(org.apache.unomi.persistence.spi.PersistenceService persistenceService)
void	setPublicAddress(String publicAddress)
void	setSchedulerService(org.apache.unomi.api.services.SchedulerService schedulerService)

Methods inherited from class java.lang.Object

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

Field Detail

KARAF_CELLAR_CLUSTER_NODE_CONFIGURATION

public static final String KARAF_CELLAR_CLUSTER_NODE_CONFIGURATION

See Also:

Constant Field Values

KARAF_CLUSTER_CONFIGURATION_PUBLIC_ENDPOINTS

public static final String KARAF_CLUSTER_CONFIGURATION_PUBLIC_ENDPOINTS

See Also:

Constant Field Values

KARAF_CLUSTER_CONFIGURATION_INTERNAL_ENDPOINTS

public static final String KARAF_CLUSTER_CONFIGURATION_INTERNAL_ENDPOINTS

See Also:

Constant Field Values

Constructor Detail

ClusterServiceImpl

public ClusterServiceImpl()

Method Detail

setPersistenceService

public void setPersistenceService(org.apache.unomi.persistence.spi.PersistenceService persistenceService)

setKarafCellarClusterManager

public void setKarafCellarClusterManager(org.apache.karaf.cellar.core.ClusterManager karafCellarClusterManager)

setKarafCellarEventProducer

public void setKarafCellarEventProducer(org.apache.karaf.cellar.core.event.EventProducer karafCellarEventProducer)

setKarafCellarGroupManager

public void setKarafCellarGroupManager(org.apache.karaf.cellar.core.GroupManager karafCellarGroupManager)

setKarafCellarGroupName

public void setKarafCellarGroupName(String karafCellarGroupName)

setOsgiConfigurationAdmin

public void setOsgiConfigurationAdmin(org.osgi.service.cm.ConfigurationAdmin osgiConfigurationAdmin)

setPublicAddress

public void setPublicAddress(String publicAddress)

setInternalAddress

public void setInternalAddress(String internalAddress)

setNodeStatisticsUpdateFrequency

public void setNodeStatisticsUpdateFrequency(long nodeStatisticsUpdateFrequency)

setSchedulerService

public void setSchedulerService(org.apache.unomi.api.services.SchedulerService schedulerService)

getNodeSystemStatistics

public Map<String,Map<String,Serializable>> getNodeSystemStatistics()

init

public void init()

destroy

public void destroy()

getClusterNodes

public List<org.apache.unomi.api.ClusterNode> getClusterNodes()

Specified by:

getClusterNodes in interface org.apache.unomi.api.services.ClusterService

purge

public void purge(Date date)

Specified by:

purge in interface org.apache.unomi.api.services.ClusterService

purge

public void purge(String scope)

Specified by:

purge in interface org.apache.unomi.api.services.ClusterService

sendEvent

public void sendEvent(Serializable eventObject)

Specified by:

sendEvent in interface org.apache.unomi.api.services.ClusterService

isClusterConfigPIDAllowed

public boolean isClusterConfigPIDAllowed(org.apache.karaf.cellar.core.Group group,
                                         String category,
                                         String pid,
                                         org.apache.karaf.cellar.core.event.EventType type)

Check if a configuration is allowed.

Parameters:

group - the cluster group.

category - the configuration category constant.

pid - the configuration PID.

type - the cluster event type.

Returns:

true if the cluster event type is allowed, false else.