pl.edu.agh.age.services.worker.internal

Class DefaultWorkerService

java.lang.Object

pl.edu.agh.age.services.worker.internal.DefaultWorkerService

All Implemented Interfaces:

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

@Named
public final class DefaultWorkerService
extends java.lang.Object
implements org.springframework.context.SmartLifecycle, WorkerCommunication, WorkerService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DefaultWorkerService.DistributedMessageListener
static class	DefaultWorkerService.Event
private static class	DefaultWorkerService.ExceptionHandler
static class	DefaultWorkerService.State

Field Summary

Fields

Modifier and Type	Field and Description
private org.springframework.context.ApplicationContext	applicationContext
private java.util.Set<CommunicationFacility>	communicationFacilities
private ComputationService	computationService
private ListeningScheduledExecutorService	executorService
private NodeIdentityService	identityService
private NodeLifecycleService	lifecycleService
private static org.slf4j.Logger	logger
private java.util.Map<WorkerMessage.Type,java.util.function.Consumer<java.io.Serializable>>	messageHandlers
private StateMachineService<DefaultWorkerService.State,DefaultWorkerService.Event>	service
private ITopic<WorkerMessage<java.io.Serializable>>	topic
private TopologyService	topologyService
private java.util.Map<WorkerMessage.Type,java.util.Set<CommunicationFacility>>	workerMessageListeners

Constructor Summary

Constructors

Modifier	Constructor and Description
private	DefaultWorkerService(NodeIdentityService identityService, org.springframework.context.ApplicationContext applicationContext, HazelcastInstance hazelcastInstance, TopologyService topologyService, EventBus eventBus, NodeLifecycleService lifecycleService)

Method Summary

Modifier and Type	Method and Description
int	getPhase()
void	handleNodeDestroyedEvent(NodeDestroyedEvent event)
private void	internalStart(FSM<DefaultWorkerService.State,DefaultWorkerService.Event> fsm)
boolean	isAutoStartup()
private boolean	isEnvironmentReady()
boolean	isRunning()
ListenableScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	sendMessage(WorkerMessage<java.io.Serializable> message) Send a message to other worker services in the distributed environment.
void	start()
void	stop()
void	stop(java.lang.Runnable callback)
private void	terminate(FSM<DefaultWorkerService.State,DefaultWorkerService.Event> fsm)

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

executorService

private final ListeningScheduledExecutorService executorService

workerMessageListeners

private final java.util.Map<WorkerMessage.Type,java.util.Set<CommunicationFacility>> workerMessageListeners

communicationFacilities

private final java.util.Set<CommunicationFacility> communicationFacilities

messageHandlers

private final java.util.Map<WorkerMessage.Type,java.util.function.Consumer<java.io.Serializable>> messageHandlers

identityService

private final NodeIdentityService identityService

lifecycleService

private final NodeLifecycleService lifecycleService

topologyService

private final TopologyService topologyService

applicationContext

private final org.springframework.context.ApplicationContext applicationContext

topic

private final ITopic<WorkerMessage<java.io.Serializable>> topic

service

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

computationService

private final ComputationService computationService

Constructor Detail

DefaultWorkerService

@Inject
private DefaultWorkerService(NodeIdentityService identityService,
                                     org.springframework.context.ApplicationContext applicationContext,
                                     HazelcastInstance hazelcastInstance,
                                     TopologyService topologyService,
                                     EventBus eventBus,
                                     NodeLifecycleService lifecycleService)

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

sendMessage

public void sendMessage(WorkerMessage<java.io.Serializable> message)

Description copied from interface: WorkerCommunication

Send a message to other worker services in the distributed environment.

Specified by:

sendMessage in interface WorkerCommunication

Parameters:

message - a message to send.

scheduleAtFixedRate

public ListenableScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command,
                                                        long initialDelay,
                                                        long period,
                                                        java.util.concurrent.TimeUnit unit)

Specified by:

scheduleAtFixedRate in interface WorkerCommunication

internalStart

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

terminate

private void terminate(FSM<DefaultWorkerService.State,DefaultWorkerService.Event> fsm)

isEnvironmentReady

private boolean isEnvironmentReady()

handleNodeDestroyedEvent

public void handleNodeDestroyedEvent(NodeDestroyedEvent event)