org.wildfly.clustering.server.singleton

Class SingletonService<T extends Serializable>

java.lang.Object

org.wildfly.clustering.server.singleton.SingletonService<T>

All Implemented Interfaces:

org.jboss.msc.service.Service<T>, org.jboss.msc.value.Value<T>, ServiceProviderRegistration.Listener, SingletonContext<T>, Singleton

public class SingletonService<T extends Serializable>
extends Object
implements org.jboss.msc.service.Service<T>, ServiceProviderRegistration.Listener, SingletonContext<T>, Singleton

Decorates an MSC service ensuring that it is only started on one node in the cluster at any given time.

Author:

Paul Ferraro

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_CACHE
static String	DEFAULT_CONTAINER

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

NULL, NULL_VALUE

Constructor Summary

Constructors

Constructor and Description
SingletonService(org.jboss.msc.service.ServiceName serviceName, org.jboss.msc.service.Service<T> service)

Method Summary

Modifier and Type	Method and Description
org.jboss.msc.service.ServiceBuilder<T>	build(org.jboss.msc.service.ServiceTarget target)
org.jboss.msc.service.ServiceBuilder<T>	build(org.jboss.msc.service.ServiceTarget target, String containerName)
org.jboss.msc.service.ServiceBuilder<T>	build(org.jboss.msc.service.ServiceTarget target, String containerName, String cacheName)
T	getValue()
AtomicReference<T>	getValueRef()
boolean	isMaster()
void	providersChanged(Set<Node> nodes) Indicates that the set of nodes providing a given service has changed.
void	setElectionPolicy(SingletonElectionPolicy electionPolicy)
void	setQuorum(int quorum)
void	start(org.jboss.msc.service.StartContext context)
void	stop(org.jboss.msc.service.StopContext context)
void	stopOldMaster()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONTAINER

public static final String DEFAULT_CONTAINER

See Also:

Constant Field Values

DEFAULT_CACHE

public static final String DEFAULT_CACHE

See Also:

Constant Field Values

Constructor Detail

SingletonService

public SingletonService(org.jboss.msc.service.ServiceName serviceName,
                        org.jboss.msc.service.Service<T> service)

Method Detail

build

public org.jboss.msc.service.ServiceBuilder<T> build(org.jboss.msc.service.ServiceTarget target)

build

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

build

public org.jboss.msc.service.ServiceBuilder<T> build(org.jboss.msc.service.ServiceTarget target,
                                                     String containerName,
                                                     String cacheName)

start

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

Specified by:

start in interface org.jboss.msc.service.Service<T extends Serializable>

stop

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

Specified by:

stop in interface org.jboss.msc.service.Service<T extends Serializable>

isMaster

public boolean isMaster()

Specified by:

isMaster in interface Singleton

setElectionPolicy

public void setElectionPolicy(SingletonElectionPolicy electionPolicy)

setQuorum

public void setQuorum(int quorum)

providersChanged

public void providersChanged(Set<Node> nodes)

Description copied from interface: ServiceProviderRegistration.Listener

Indicates that the set of nodes providing a given service has changed.

Specified by:

providersChanged in interface ServiceProviderRegistration.Listener

Parameters:

nodes - the new set of nodes providing the given service

getValue

public T getValue()

Specified by:

getValue in interface org.jboss.msc.value.Value<T extends Serializable>

getValueRef

public AtomicReference<T> getValueRef()

Specified by:

getValueRef in interface SingletonContext<T extends Serializable>

stopOldMaster

public void stopOldMaster()

Specified by:

stopOldMaster in interface SingletonContext<T extends Serializable>