pl.edu.agh.age.client.hazelcast

Class HazelcastWorkerServiceClient

java.lang.Object

pl.edu.agh.age.client.hazelcast.HazelcastWorkerServiceClient

All Implemented Interfaces:

WorkerServiceClient

@Named
public final class HazelcastWorkerServiceClient
extends java.lang.Object
implements WorkerServiceClient

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	logger
private static ImmutableSet<ComputationState>	NOT_FINISHED_STATES
private java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object>	workerConfigurationMap
private ITopic<WorkerMessage<?>>	workerTopic

Constructor Summary

Constructors

Constructor and Description
HazelcastWorkerServiceClient(HazelcastInstance hazelcastInstance)

Method Summary

Modifier and Type	Method and Description
void	cleanConfiguration()
ComputationState	computationState()
private <T> java.util.Optional<T>	configurationValue(HazelcastObjectNames.ConfigurationKey key)
java.util.Optional<WorkerConfiguration>	currentConfiguration()
java.util.Optional<java.lang.Throwable>	currentError()
boolean	isComputationFailed()
boolean	isComputationFinished()
boolean	isComputationRunning()
void	prepareConfiguration(WorkerConfiguration configuration)
void	startComputation()
void	stopComputation()
void	waitForComputationEnd()

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

NOT_FINISHED_STATES

private static final ImmutableSet<ComputationState> NOT_FINISHED_STATES

workerTopic

private final ITopic<WorkerMessage<?>> workerTopic

workerConfigurationMap

private final java.util.Map<HazelcastObjectNames.ConfigurationKey,java.lang.Object> workerConfigurationMap

Constructor Detail

HazelcastWorkerServiceClient

@Inject
public HazelcastWorkerServiceClient(HazelcastInstance hazelcastInstance)

Method Detail

startComputation

public void startComputation()

Specified by:

startComputation in interface WorkerServiceClient

stopComputation

public void stopComputation()

Specified by:

stopComputation in interface WorkerServiceClient

cleanConfiguration

public void cleanConfiguration()

Specified by:

cleanConfiguration in interface WorkerServiceClient

prepareConfiguration

public void prepareConfiguration(WorkerConfiguration configuration)
                          throws java.lang.InterruptedException

Specified by:

prepareConfiguration in interface WorkerServiceClient

Throws:

java.lang.InterruptedException

isComputationRunning

public boolean isComputationRunning()

Specified by:

isComputationRunning in interface WorkerServiceClient

isComputationFinished

public boolean isComputationFinished()

Specified by:

isComputationFinished in interface WorkerServiceClient

isComputationFailed

public boolean isComputationFailed()

Specified by:

isComputationFailed in interface WorkerServiceClient

computationState

public ComputationState computationState()

Specified by:

computationState in interface WorkerServiceClient

currentConfiguration

public java.util.Optional<WorkerConfiguration> currentConfiguration()

Specified by:

currentConfiguration in interface WorkerServiceClient

currentError

public java.util.Optional<java.lang.Throwable> currentError()

Specified by:

currentError in interface WorkerServiceClient

waitForComputationEnd

public void waitForComputationEnd()
                           throws java.lang.InterruptedException

Specified by:

waitForComputationEnd in interface WorkerServiceClient

Throws:

java.lang.InterruptedException

configurationValue

private <T> java.util.Optional<T> configurationValue(HazelcastObjectNames.ConfigurationKey key)