org.wildfly.clustering.server.group

Class CacheGroupService

java.lang.Object

org.wildfly.clustering.server.group.CacheGroupService

All Implemented Interfaces:

org.jboss.msc.service.Service<Group>, org.jboss.msc.value.Value<Group>, Group

public class CacheGroupService
extends Object
implements Group, org.jboss.msc.service.Service<Group>

Group implementation based on a cache view.

Author:

Paul Ferraro

Nested Class Summary

Nested classes/interfaces inherited from interface org.wildfly.clustering.group.Group

Group.Listener

Field Summary

Fields inherited from interface org.jboss.msc.service.Service

NULL, NULL_VALUE

Constructor Summary

Constructors

Constructor and Description
CacheGroupService(CacheGroupConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	addListener(Group.Listener listener) Registers a membership listener for the group.
Node	getCoordinatorNode() Returns the group coordinator node.
Node	getLocalNode() Returns the local node.
String	getName() Returns the name of this group.
List<Node>	getNodes() Returns the list of nodes that are members of this group.
Group	getValue()
boolean	isCoordinator() Indicates whether or not we are the group coordinator.
void	removeListener(Group.Listener listener) Removes a registered listener from the group.
void	start(org.jboss.msc.service.StartContext context)
void	stop(org.jboss.msc.service.StopContext context)
void	topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<?,?> event)

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheGroupService

public CacheGroupService(CacheGroupConfiguration config)

Method Detail

getValue

public Group getValue()

Specified by:

getValue in interface org.jboss.msc.value.Value<Group>

start

public void start(org.jboss.msc.service.StartContext context)

Specified by:

start in interface org.jboss.msc.service.Service<Group>

stop

public void stop(org.jboss.msc.service.StopContext context)

Specified by:

stop in interface org.jboss.msc.service.Service<Group>

getName

public String getName()

Description copied from interface: Group

Returns the name of this group.

Specified by:

getName in interface Group

Returns:

the group name

isCoordinator

public boolean isCoordinator()

Description copied from interface: Group

Indicates whether or not we are the group coordinator.

Specified by:

isCoordinator in interface Group

Returns:

true, if we are the group coordinator, false otherwise

getLocalNode

public Node getLocalNode()

Description copied from interface: Group

Returns the local node.

Specified by:

getLocalNode in interface Group

Returns:

the local node

getCoordinatorNode

public Node getCoordinatorNode()

Description copied from interface: Group

Returns the group coordinator node.

Specified by:

getCoordinatorNode in interface Group

Returns:

the group coordinator node

getNodes

public List<Node> getNodes()

Description copied from interface: Group

Returns the list of nodes that are members of this group.

Specified by:

getNodes in interface Group

Returns:

a list of nodes

topologyChanged

public void topologyChanged(org.infinispan.notifications.cachelistener.event.TopologyChangedEvent<?,?> event)

addListener

public void addListener(Group.Listener listener)

Description copied from interface: Group

Registers a membership listener for the group.

Specified by:

addListener in interface Group

Parameters:

listener - listener to be added

removeListener

public void removeListener(Group.Listener listener)

Description copied from interface: Group

Removes a registered listener from the group.

Specified by:

removeListener in interface Group

Parameters:

listener - listener to be removed