pl.edu.agh.age.services.status.internal

Class DefaultStatusService

java.lang.Object

pl.edu.agh.age.services.status.internal.DefaultStatusService

All Implemented Interfaces:

org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle

@Named
public final class DefaultStatusService
extends java.lang.Object
implements org.springframework.context.SmartLifecycle

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	DefaultStatusService.MapUpdateCallback

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List<java.lang.Throwable>	collectedErrors
private EventBus	eventBus
private ListeningScheduledExecutorService	executorService
private NodeIdentityService	identityService
private NodeLifecycleService	lifecycleService
private static org.slf4j.Logger	logger
private java.lang.String	nodeId
private java.util.concurrent.atomic.AtomicBoolean	running
private IMap<java.lang.String,Status>	statusMap
private static @s long	UPDATE_PERIOD_IN_S

Constructor Summary

Constructors

Constructor and Description
DefaultStatusService(NodeIdentityService identityService, NodeLifecycleService lifecycleService, HazelcastInstance hazelcastInstance, EventBus eventBus)

Method Summary

Modifier and Type	Method and Description
int	getPhase()
void	handleServiceFailureEvent(ServiceFailureEvent event)
boolean	isAutoStartup()
boolean	isRunning()
void	start()
void	stop()
void	stop(java.lang.Runnable callback)
private void	updateMap()

Methods inherited from class java.lang.Object

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

Field Detail

UPDATE_PERIOD_IN_S

private static final @s long UPDATE_PERIOD_IN_S

See Also:

Constant Field Values

logger

private static final org.slf4j.Logger logger

executorService

private final ListeningScheduledExecutorService executorService

running

private final java.util.concurrent.atomic.AtomicBoolean running

collectedErrors

private final java.util.List<java.lang.Throwable> collectedErrors

identityService

private final NodeIdentityService identityService

lifecycleService

private final NodeLifecycleService lifecycleService

eventBus

private final EventBus eventBus

nodeId

private final java.lang.String nodeId

statusMap

private final IMap<java.lang.String,Status> statusMap

Constructor Detail

DefaultStatusService

@Inject
public DefaultStatusService(NodeIdentityService identityService,
                                    NodeLifecycleService lifecycleService,
                                    HazelcastInstance hazelcastInstance,
                                    EventBus eventBus)

Method Detail

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

stop

public void stop(java.lang.Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

updateMap

private void updateMap()

handleServiceFailureEvent

public void handleServiceFailureEvent(ServiceFailureEvent event)