public class SingletonService<T extends Serializable> extends AsynchronousService<T> implements ServiceProviderRegistry.Listener, org.jboss.msc.service.StopContext, SingletonRpcHandler<T>
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_CONTAINER |
Constructor and Description |
---|
SingletonService(org.jboss.msc.service.Service<T> service,
org.jboss.msc.service.ServiceName serviceName) |
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() |
stop
public static final String DEFAULT_CONTAINER
public SingletonService(org.jboss.msc.service.Service<T> service, org.jboss.msc.service.ServiceName serviceName)
public org.jboss.msc.service.ServiceBuilder<T> build(org.jboss.msc.service.ServiceContainer target)
public org.jboss.msc.service.ServiceBuilder<T> build(org.jboss.msc.service.ServiceContainer target, String container)
public void start(org.jboss.msc.service.StartContext context) throws org.jboss.msc.service.StartException
start
in interface org.jboss.msc.service.Service<T extends Serializable>
start
in class AsynchronousService<T extends Serializable>
org.jboss.msc.service.StartException
protected void start()
start
in class AsynchronousService<T extends Serializable>
protected void stop()
stop
in class AsynchronousService<T extends Serializable>
public void setElectionPolicy(SingletonElectionPolicy electionPolicy)
public void setRestartOnMerge(boolean restart)
public void serviceProvidersChanged(Set<ClusterNode> nodes, boolean merge)
ServiceProviderRegistry.Listener
serviceProvidersChanged
in interface ServiceProviderRegistry.Listener
nodes
- the new set of nodes providing the given servicemerge
- indicates whether or not this provision change was the result of a network partition merge.public T getValue()
getValue
in interface org.jboss.msc.value.Value<T extends Serializable>
public AtomicReference<T> getValueRef()
getValueRef
in interface SingletonRpcHandler<T extends Serializable>
public void stopOldMaster()
stopOldMaster
in interface SingletonRpcHandler<T extends Serializable>
public void asynchronous() throws IllegalStateException
asynchronous
in interface org.jboss.msc.service.LifecycleContext
IllegalStateException
public void complete() throws IllegalStateException
complete
in interface org.jboss.msc.service.LifecycleContext
IllegalStateException
public long getElapsedTime()
getElapsedTime
in interface org.jboss.msc.service.LifecycleContext
public org.jboss.msc.service.ServiceController<?> getController()
getController
in interface org.jboss.msc.service.LifecycleContext
Copyright © 2012 JBoss, a division of Red Hat, Inc.. All Rights Reserved.