org.wildfly.clustering.server.provider

Class CacheServiceProviderRegistry<T>

java.lang.Object

org.wildfly.clustering.server.provider.CacheServiceProviderRegistry<T>

All Implemented Interfaces:

AutoCloseable, Group.Listener, ServiceProviderRegistry<T>

public class CacheServiceProviderRegistry<T>
extends Object
implements ServiceProviderRegistry<T>, Group.Listener, AutoCloseable

Infinispan Cache based ServiceProviderRegistrationFactory. This factory can create multiple ServiceProviderRegistration instance, all of which share the same Cache instance.

Author:

Paul Ferraro

Constructor Summary

Constructors

Constructor and Description
CacheServiceProviderRegistry(CacheServiceProviderRegistryConfiguration<T> config)

Method Summary

Modifier and Type	Method and Description
void	close()
Group	getGroup() Returns the group with which to register service providers.
Set<Node>	getProviders(T service) Returns the set of nodes that can provide the specified service.
Set<T>	getServices() Returns the complete list of services known to this registry.
void	membershipChanged(List<Node> previousMembers, List<Node> members, boolean merged) Indicates that the membership of the group has changed.
void	modified(org.infinispan.notifications.cachelistener.event.CacheEntryEvent<org.jboss.msc.service.ServiceName,Set<Node>> event)
ServiceProviderRegistration<T>	register(T service) Registers the local node as providing the specified service.
ServiceProviderRegistration<T>	register(T service, ServiceProviderRegistration.Listener listener) Registers the local node as providing the specified service, using the specified listener.

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheServiceProviderRegistry

public CacheServiceProviderRegistry(CacheServiceProviderRegistryConfiguration<T> config)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

getGroup

public Group getGroup()

Description copied from interface: ServiceProviderRegistry

Returns the group with which to register service providers.

Specified by:

getGroup in interface ServiceProviderRegistry<T>

Returns:

a group

register

public ServiceProviderRegistration<T> register(T service)

Description copied from interface: ServiceProviderRegistry

Registers the local node as providing the specified service.

Specified by:

register in interface ServiceProviderRegistry<T>

Parameters:

service - a service to register

Returns:

a new service provider registration

register

public ServiceProviderRegistration<T> register(T service,
                                               ServiceProviderRegistration.Listener listener)

Description copied from interface: ServiceProviderRegistry

Registers the local node as providing the specified service, using the specified listener.

Specified by:

register in interface ServiceProviderRegistry<T>

Parameters:

service - a service to register

listener - a registry listener

Returns:

a new service provider registration

getProviders

public Set<Node> getProviders(T service)

Description copied from interface: ServiceProviderRegistry

Returns the set of nodes that can provide the specified service.

Specified by:

getProviders in interface ServiceProviderRegistry<T>

Parameters:

service - a service to obtain providers for

Returns:

a set of nodes

getServices

public Set<T> getServices()

Description copied from interface: ServiceProviderRegistry

Returns the complete list of services known to this registry.

Specified by:

getServices in interface ServiceProviderRegistry<T>

Returns:

a set of services

membershipChanged

public void membershipChanged(List<Node> previousMembers,
                              List<Node> members,
                              boolean merged)

Description copied from interface: Group.Listener

Indicates that the membership of the group has changed.

Specified by:

membershipChanged in interface Group.Listener

Parameters:

previousMembers - previous group members

members - new group members

merged - indicates whether the membership change is the result of a merge view

modified

public void modified(org.infinispan.notifications.cachelistener.event.CacheEntryEvent<org.jboss.msc.service.ServiceName,Set<Node>> event)