org.spf4j.concurrent

Class RestartableServiceImpl

java.lang.Object

org.spf4j.concurrent.RestartableServiceImpl

All Implemented Interfaces:

com.google.common.util.concurrent.Service, AutoCloseable, RestartableService

Direct Known Subclasses:

TcpServer

@Beta
public abstract class RestartableServiceImpl
extends Object
implements RestartableService

Author:

zoly

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
RestartableServiceImpl(com.google.common.base.Supplier<com.google.common.util.concurrent.Service> supplier)

Method Summary

Modifier and Type	Method and Description
void	addListener(com.google.common.util.concurrent.Service.Listener listener, Executor executor)
void	awaitRunning()
void	awaitRunning(long timeout, TimeUnit unit)
void	awaitTerminated()
void	awaitTerminated(long timeout, TimeUnit unit)
void	close()
Throwable	failureCause()
boolean	isRunning()
void	jmxStart()
void	jmxStop()
void	registerToJmx()
com.google.common.util.concurrent.Service	startAsync()
com.google.common.util.concurrent.Service.State	state()
com.google.common.util.concurrent.Service	stopAsync()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.spf4j.concurrent.RestartableService

getServiceName

Constructor Detail

RestartableServiceImpl

public RestartableServiceImpl(com.google.common.base.Supplier<com.google.common.util.concurrent.Service> supplier)

Method Detail

registerToJmx

public final void registerToJmx()

jmxStart

public final void jmxStart()

startAsync

public final com.google.common.util.concurrent.Service startAsync()

Specified by:

startAsync in interface com.google.common.util.concurrent.Service

isRunning

public final boolean isRunning()

Specified by:

isRunning in interface com.google.common.util.concurrent.Service

state

public final com.google.common.util.concurrent.Service.State state()

Specified by:

state in interface com.google.common.util.concurrent.Service

jmxStop

public final void jmxStop()

stopAsync

public final com.google.common.util.concurrent.Service stopAsync()

Specified by:

stopAsync in interface com.google.common.util.concurrent.Service

awaitRunning

public final void awaitRunning()

Specified by:

awaitRunning in interface com.google.common.util.concurrent.Service

awaitRunning

public final void awaitRunning(long timeout,
                               TimeUnit unit)
                        throws TimeoutException

Specified by:

awaitRunning in interface com.google.common.util.concurrent.Service

Throws:

TimeoutException

awaitTerminated

public final void awaitTerminated()

Specified by:

awaitTerminated in interface com.google.common.util.concurrent.Service

awaitTerminated

public final void awaitTerminated(long timeout,
                                  TimeUnit unit)
                           throws TimeoutException

Specified by:

awaitTerminated in interface com.google.common.util.concurrent.Service

Throws:

TimeoutException

failureCause

public final Throwable failureCause()

Specified by:

failureCause in interface com.google.common.util.concurrent.Service

addListener

public final void addListener(com.google.common.util.concurrent.Service.Listener listener,
                              Executor executor)

Specified by:

addListener in interface com.google.common.util.concurrent.Service

close

public final void close()

Specified by:

close in interface AutoCloseable

toString

public final String toString()

Overrides:

toString in class Object