io.sarl.sre.services

Class GoogleServiceManager

java.lang.Object

io.sarl.sre.services.AbstractServiceManager

io.sarl.sre.services.GoogleServiceManager

All Implemented Interfaces:

IServiceManager

public class GoogleServiceManager
extends AbstractServiceManager

Implementation of a service manager based on the Google service manager.

Version:

io.janusproject.plugin 0.12.0 20210527-171007

Author:

Stéphane Galland

Maven Group Id:

io.janusproject.sre

Maven Artifact Id:

io.janusproject.plugin

Constructor Summary

Constructors

Constructor and Description
GoogleServiceManager(services : Iterable<? extends com.google.common.util.concurrent.Service>, config : SreConfig)
GoogleServiceManager(sm : com.google.common.util.concurrent.ServiceManager, config : SreConfig)

Method Summary

Modifier and Type	Method and Description
void	awaitHealthy() Wait for all the services are started.
void	awaitStopped() Wait for all the services are stopped.
<T extends com.google.common.util.concurrent.Service> T	getService(type : Class<T>) Replies the service of the given type.
com.google.common.collect.Multimap<com.google.common.util.concurrent.Service.State,com.google.common.util.concurrent.Service>	getServicesByState() Replies the services by state.
protected void	internalStartAllServices() Start all the services whatever the dependencies between the services.
protected void	internalStopAllServices() Stop all the services whatever the dependencies between the services.

Methods inherited from class io.sarl.sre.services.AbstractServiceManager

getLogger, preStop, setLogger, startServices, stopServices

Methods inherited from class java.lang.Object

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

Constructor Detail

GoogleServiceManager

public new(sm : com.google.common.util.concurrent.ServiceManager,
           config : SreConfig)

Parameters:

sm - the Google service to use.

config - the configuration.

GoogleServiceManager

public new(services : Iterable<? extends com.google.common.util.concurrent.Service>,
           config : SreConfig)

Parameters:

services - the services to manager.

config - the configuration.

Method Detail

getServicesByState

@Pure
public def getServicesByState() : com.google.common.collect.Multimap<com.google.common.util.concurrent.Service.State,com.google.common.util.concurrent.Service> 

Description copied from interface: IServiceManager

Replies the services by state.

Returns:

the services.

getService

@Pure
public def getService(type : Class<T>) : T  with <T extends com.google.common.util.concurrent.Service> 

Description copied from interface: IServiceManager

Replies the service of the given type.

Parameters:

type - the type of the service to search for.

Returns:

the service

awaitHealthy

public def awaitHealthy() : void 

Description copied from interface: IServiceManager

Wait for all the services are started.

internalStartAllServices

protected def internalStartAllServices() : void 

Description copied from class: AbstractServiceManager

Start all the services whatever the dependencies between the services.

Specified by:

internalStartAllServices in class AbstractServiceManager

internalStopAllServices

protected def internalStopAllServices() : void 

Description copied from class: AbstractServiceManager

Stop all the services whatever the dependencies between the services.

Specified by:

internalStopAllServices in class AbstractServiceManager

awaitStopped

public def awaitStopped() : void 

Description copied from interface: IServiceManager

Wait for all the services are stopped.