org.jboss.as.clustering.service

Class ServiceProviderRegistryService

java.lang.Object

org.jboss.as.clustering.service.ServiceProviderRegistryService

All Implemented Interfaces:

GroupMembershipListener, ServiceProviderRegistry, org.jboss.msc.service.Service<ServiceProviderRegistry>, org.jboss.msc.value.Value<ServiceProviderRegistry>

public class ServiceProviderRegistryService
extends Object
implements ServiceProviderRegistry, GroupMembershipListener, org.jboss.msc.service.Service<ServiceProviderRegistry>

Author:

Paul Ferraro

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.as.clustering.service.ServiceProviderRegistry

ServiceProviderRegistry.Listener

Field Summary

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

NULL, NULL_VALUE

Constructor Summary

Constructors

Constructor and Description
ServiceProviderRegistryService()

Method Summary

Methods

Modifier and Type	Method and Description
org.jboss.msc.service.ServiceBuilder<ServiceProviderRegistry>	build(org.jboss.msc.service.ServiceTarget target, String container)
static org.jboss.msc.service.ServiceName	getServiceName(String name)
Set<ClusterNode>	getServiceProviders(String service) Returns the set of nodes that provide the specified service.
ServiceProviderRegistry	getValue()
void	membershipChanged(List<ClusterNode> deadMembers, List<ClusterNode> newMembers, List<ClusterNode> allMembers) Called when a partition topology change occurs.
void	membershipChangedDuringMerge(List<ClusterNode> deadMembers, List<ClusterNode> newMembers, List<ClusterNode> allMembers, List<List<ClusterNode>> originatingGroups) Specialized notification issued instead of the standard one when a network-partition merge occurs.
void	modified(org.infinispan.notifications.cachelistener.event.CacheEntryModifiedEvent<String,Map<ClusterNode,Void>> event)
void	register(String service, ServiceProviderRegistry.Listener listener) Registers the current node as a provider for the specified service.
void	start(org.jboss.msc.service.StartContext context)
void	stop(org.jboss.msc.service.StopContext context)
void	unregister(String service) Unregisters the current node as a provider for the specified service.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceProviderRegistryService

public ServiceProviderRegistryService()

Method Detail

getServiceName

public static org.jboss.msc.service.ServiceName getServiceName(String name)

build

public org.jboss.msc.service.ServiceBuilder<ServiceProviderRegistry> build(org.jboss.msc.service.ServiceTarget target,
                                                                  String container)

register

public void register(String service,
            ServiceProviderRegistry.Listener listener)

Description copied from interface: ServiceProviderRegistry

Registers the current node as a provider for the specified service.

Specified by:

register in interface ServiceProviderRegistry

Parameters:

service - the name of the provided service.

listener - the object to notify in the event the set of nodes providing the specified service changes.

unregister

public void unregister(String service)

Description copied from interface: ServiceProviderRegistry

Unregisters the current node as a provider for the specified service.

Specified by:

unregister in interface ServiceProviderRegistry

Parameters:

service - a service name.

getServiceProviders

public Set<ClusterNode> getServiceProviders(String service)

Description copied from interface: ServiceProviderRegistry

Returns the set of nodes that provide the specified service.

Specified by:

getServiceProviders in interface ServiceProviderRegistry

Parameters:

service - a service name

Returns:

a set of nodes.

getValue

public ServiceProviderRegistry getValue()
                                 throws IllegalStateException,
                                        IllegalArgumentException

Specified by:

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

Throws:

IllegalStateException

IllegalArgumentException

start

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

Specified by:

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

Throws:

org.jboss.msc.service.StartException

stop

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

Specified by:

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

membershipChanged

public void membershipChanged(List<ClusterNode> deadMembers,
                     List<ClusterNode> newMembers,
                     List<ClusterNode> allMembers)

Description copied from interface: GroupMembershipListener

Called when a partition topology change occurs. This callback will not be made using the thread that carries messages up from the network.

Specified by:

membershipChanged in interface GroupMembershipListener

Parameters:

deadMembers - A list of nodes that have died since the previous view

newMembers - A list of nodes that have joined the partition since the previous view

allMembers - A list of nodes that built the current view

membershipChangedDuringMerge

public void membershipChangedDuringMerge(List<ClusterNode> deadMembers,
                                List<ClusterNode> newMembers,
                                List<ClusterNode> allMembers,
                                List<List<ClusterNode>> originatingGroups)

Description copied from interface: GroupMembershipListener

Specialized notification issued instead of the standard one when a network-partition merge occurs. This callback will not be made using the thread that carries messages up from the network.

Specified by:

membershipChangedDuringMerge in interface GroupMembershipListener

Parameters:

deadMembers - A list of nodes that have died since the previous view

newMembers - A list of nodes that have joined the partition since the previous view

allMembers - A list of nodes that built the current view

originatingGroups - A list of nodes that were previously partioned and that are now merged

modified

public void modified(org.infinispan.notifications.cachelistener.event.CacheEntryModifiedEvent<String,Map<ClusterNode,Void>> event)