public class ServiceProviderRegistryService extends Object implements ServiceProviderRegistry, GroupMembershipListener, org.jboss.msc.service.Service<ServiceProviderRegistry>
ServiceProviderRegistry.Listener
Constructor and Description |
---|
ServiceProviderRegistryService() |
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.
|
public static org.jboss.msc.service.ServiceName getServiceName(String name)
public org.jboss.msc.service.ServiceBuilder<ServiceProviderRegistry> build(org.jboss.msc.service.ServiceTarget target, String container)
public void register(String service, ServiceProviderRegistry.Listener listener)
ServiceProviderRegistry
register
in interface ServiceProviderRegistry
service
- the name of the provided service.listener
- the object to notify in the event the set of nodes providing the specified service changes.public void unregister(String service)
ServiceProviderRegistry
unregister
in interface ServiceProviderRegistry
service
- a service name.public Set<ClusterNode> getServiceProviders(String service)
ServiceProviderRegistry
getServiceProviders
in interface ServiceProviderRegistry
service
- a service namepublic ServiceProviderRegistry getValue() throws IllegalStateException, IllegalArgumentException
getValue
in interface org.jboss.msc.value.Value<ServiceProviderRegistry>
IllegalStateException
IllegalArgumentException
public void start(org.jboss.msc.service.StartContext context) throws org.jboss.msc.service.StartException
start
in interface org.jboss.msc.service.Service<ServiceProviderRegistry>
org.jboss.msc.service.StartException
public void stop(org.jboss.msc.service.StopContext context)
stop
in interface org.jboss.msc.service.Service<ServiceProviderRegistry>
public void membershipChanged(List<ClusterNode> deadMembers, List<ClusterNode> newMembers, List<ClusterNode> allMembers)
GroupMembershipListener
membershipChanged
in interface GroupMembershipListener
deadMembers
- A list of nodes that have died since the previous viewnewMembers
- A list of nodes that have joined the partition since the previous viewallMembers
- A list of nodes that built the current viewpublic void membershipChangedDuringMerge(List<ClusterNode> deadMembers, List<ClusterNode> newMembers, List<ClusterNode> allMembers, List<List<ClusterNode>> originatingGroups)
GroupMembershipListener
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.membershipChangedDuringMerge
in interface GroupMembershipListener
deadMembers
- A list of nodes that have died since the previous viewnewMembers
- A list of nodes that have joined the partition since the previous viewallMembers
- A list of nodes that built the current vieworiginatingGroups
- A list of nodes that were previously partioned and that are now mergedpublic void modified(org.infinispan.notifications.cachelistener.event.CacheEntryModifiedEvent<String,Map<ClusterNode,Void>> event)
Copyright © 2013 JBoss, a division of Red Hat, Inc.. All rights reserved.