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:

Executor, ServiceProviderRegistry.Listener, SingletonRpcHandler<T>, org.jboss.msc.service.LifecycleContext, org.jboss.msc.service.Service<T>, org.jboss.msc.service.StopContext, org.jboss.msc.value.Value<T>

public class SingletonService<T extends Serializable>
extends AsynchronousService<T>
implements ServiceProviderRegistry.Listener, org.jboss.msc.service.StopContext, SingletonRpcHandler<T>

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
void	asynchronous()
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)
void	complete()
void	execute(Runnable command)
org.jboss.msc.service.ServiceController<?>	getController()
long	getElapsedTime()
T	getValue()
AtomicReference<T>	getValueRef()
void	serviceProvidersChanged(Set<ClusterNode> nodes, boolean merge) Indicates that the set of nodes providing a given service has changed.
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>

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>

asynchronous

public void asynchronous()
                  throws IllegalStateException

Specified by:

asynchronous in interface org.jboss.msc.service.LifecycleContext

Throws:

IllegalStateException

complete

public void complete()
              throws IllegalStateException

Specified by:

complete in interface org.jboss.msc.service.LifecycleContext

Throws:

IllegalStateException

getElapsedTime

public long getElapsedTime()

Specified by:

getElapsedTime in interface org.jboss.msc.service.LifecycleContext

getController

public org.jboss.msc.service.ServiceController<?> getController()

Specified by:

getController in interface org.jboss.msc.service.LifecycleContext

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Specified by:

execute in interface org.jboss.msc.service.LifecycleContext