pl.edu.agh.age.services.lifecycle.internal

Class DefaultNodeLifecycleService

java.lang.Object

pl.edu.agh.age.services.lifecycle.internal.DefaultNodeLifecycleService

All Implemented Interfaces:

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

@Named
public final class DefaultNodeLifecycleService
extends java.lang.Object
implements org.springframework.context.SmartLifecycle, NodeLifecycleService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DefaultNodeLifecycleService.DistributedMessageListener
static class	DefaultNodeLifecycleService.Event Events that can occur in the node.
private static class	DefaultNodeLifecycleService.ExceptionHandler
static class	DefaultNodeLifecycleService.State States of this lifecycle manager (in other words - states of the node).

Field Summary

Fields

Modifier and Type	Field and Description
private EventBus	eventBus
private static org.slf4j.Logger	logger
private java.util.EnumMap<LifecycleMessage.Type,java.util.function.Consumer<java.io.Serializable>>	messageHandlers
private StateMachineService<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event>	service
private ITopic<LifecycleMessage>	topic

Constructor Summary

Constructors

Constructor and Description
DefaultNodeLifecycleService(HazelcastInstance hazelcastInstance, EventBus eventBus)

Method Summary

Modifier and Type	Method and Description
void	awaitTermination()
private void	connectionDown(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)
int	getPhase()
private void	handleDestroy(@Nullable java.io.Serializable serializable)
void	handleDiscoveryServiceStoppingEvent(DiscoveryServiceStoppingEvent event)
private void	internalStart(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)
private void	internalStop(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)
boolean	isAutoStartup()
boolean	isRunning()
boolean	isTerminated()
private void	reconnected(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)
void	start()
void	stop()
void	stop(java.lang.Runnable callback)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final org.slf4j.Logger logger

eventBus

private final EventBus eventBus

topic

private final ITopic<LifecycleMessage> topic

service

private final StateMachineService<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> service

messageHandlers

private final java.util.EnumMap<LifecycleMessage.Type,java.util.function.Consumer<java.io.Serializable>> messageHandlers

Constructor Detail

DefaultNodeLifecycleService

@Inject
public DefaultNodeLifecycleService(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

Specified by:

isRunning in interface NodeLifecycleService

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

awaitTermination

public void awaitTermination()
                      throws java.lang.InterruptedException

Specified by:

awaitTermination in interface NodeLifecycleService

Throws:

java.lang.InterruptedException

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface NodeLifecycleService

internalStart

private void internalStart(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)

internalStop

private void internalStop(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)

connectionDown

private void connectionDown(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)

reconnected

private void reconnected(FSM<DefaultNodeLifecycleService.State,DefaultNodeLifecycleService.Event> fsm)

handleDestroy

private void handleDestroy(@Nullable java.io.Serializable serializable)

handleDiscoveryServiceStoppingEvent

public void handleDiscoveryServiceStoppingEvent(DiscoveryServiceStoppingEvent event)