public class SingletonService<T extends Serializable> extends AsynchronousService<T> implements ServiceProviderRegistry.Listener, SingletonRpcHandler<T>, Singleton
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 |
---|---|
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() |
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 setClassResolver(org.jboss.marshalling.ClassResolver resolver)
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>
Copyright © 2013 JBoss, a division of Red Hat, Inc.. All rights reserved.