org.jboss.as.clustering.singleton

Class SingletonService<T extends Serializable>

java.lang.Object

org.jboss.as.clustering.msc.AsynchronousService<T>

org.jboss.as.clustering.singleton.SingletonService<T>

All Implemented Interfaces:

ServiceProviderRegistry.Listener, Singleton, SingletonRpcHandler<T>, org.jboss.msc.service.Service<T>, org.jboss.msc.value.Value<T>

public class SingletonService<T extends Serializable>
extends AsynchronousService<T>
implements ServiceProviderRegistry.Listener, SingletonRpcHandler<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_CONTAINER

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

NULL, NULL_VALUE

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
org.jboss.msc.service.ServiceBuilder<T>	build(org.jboss.msc.service.ServiceContainer target)
org.jboss.msc.service.ServiceBuilder<T>	build(org.jboss.msc.service.ServiceContainer target, String container)
T	getValue()
AtomicReference<T>	getValueRef()
boolean	isMaster()
void	serviceProvidersChanged(Set<ClusterNode> nodes, boolean merge) Indicates that the set of nodes providing a given service has changed.
void	setClassResolver(org.jboss.marshalling.ClassResolver resolver)
void	setElectionPolicy(SingletonElectionPolicy electionPolicy)
void	setRestartOnMerge(boolean restart)
protected void	start()
void	start(org.jboss.msc.service.StartContext context)
protected void	stop()
void	stopOldMaster()

Methods inherited from class org.jboss.as.clustering.msc.AsynchronousService

stop

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

Constructor Detail

SingletonService

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

Method Detail

build

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

build

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

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<T extends Serializable>

Overrides:

start in class AsynchronousService<T extends Serializable>

Throws:

org.jboss.msc.service.StartException

start

protected void start()

Specified by:

start in class AsynchronousService<T extends Serializable>

stop

protected void stop()

Specified by:

stop in class AsynchronousService<T extends Serializable>

isMaster

public boolean isMaster()

Specified by:

isMaster in interface Singleton

setClassResolver

public void setClassResolver(org.jboss.marshalling.ClassResolver resolver)

setElectionPolicy

public void setElectionPolicy(SingletonElectionPolicy electionPolicy)

setRestartOnMerge

public void setRestartOnMerge(boolean restart)

serviceProvidersChanged

public void serviceProvidersChanged(Set<ClusterNode> nodes,
                           boolean merge)

Description copied from interface: ServiceProviderRegistry.Listener

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

Specified by:

serviceProvidersChanged in interface ServiceProviderRegistry.Listener

Parameters:

nodes - the new set of nodes providing the given service

merge - indicates whether or not this provision change was the result of a network partition merge.

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 SingletonRpcHandler<T extends Serializable>

stopOldMaster

public void stopOldMaster()

Specified by:

stopOldMaster in interface SingletonRpcHandler<T extends Serializable>