Package dev.getelements.elements.rt.remote

Class SimpleWorkerInstance

java.lang.Object

dev.getelements.elements.rt.remote.SimpleInstance

dev.getelements.elements.rt.remote.SimpleWorkerInstance

All Implemented Interfaces:

Instance, Worker, AutoCloseable

public class SimpleWorkerInstance
extends SimpleInstance
implements Worker

Contains all Node instances for several Node instances and manages their life cycles therein. This imposes the additional requirement of providing some form of InstanceConnectionService to route internal requests.

Nested Class Summary

Nested classes/interfaces inherited from interface dev.getelements.elements.rt.remote.Worker

Worker.Accessor, Worker.Mutator

Field Summary

Fields inherited from class dev.getelements.elements.rt.remote.SimpleInstance

instanceId

Fields inherited from interface dev.getelements.elements.rt.remote.Instance

EXECUTOR_SERVICE, SCHEDULED_EXECUTOR_SERVICE, THREAD_GROUP

Constructor Summary

Constructors

Constructor	Description
SimpleWorkerInstance()

Method Summary

Modifier and Type	Method	Description
Worker.Accessor	accessWorkerState()	Opens an Worker.Accessor which can be used to read the run-state of this Worker.
Worker.Mutator	beginMutation()	Opens a Worker.Mutator which can be used to modify the run-state of this Worker.
InstanceId	getInstanceId()	Gets this instances InstanceId
Node	getMasterNode()
Node.Factory	getNodeFactory()
Set<Node>	getNodeSet()
PersistenceEnvironment	getPersistenceEnvironment()
protected void	postClose(Consumer<Exception> exceptionConsumer)
protected void	postStart(Consumer<Exception> exceptionConsumer)
protected void	preClose(Consumer<Exception> exceptionConsumer)
protected void	preStart(Consumer<Exception> exceptionConsumer)
void	setInstanceId(InstanceId instanceId)
void	setMasterNode(Node masterNode)
void	setNodeFactory(Node.Factory nodeFactory)
void	setNodeSet(Set<Node> nodeSet)
void	setPersistenceEnvironment(PersistenceEnvironment persistenceEnvironment)

Methods inherited from class dev.getelements.elements.rt.remote.SimpleInstance

close, getAsyncConnectionService, getInstanceConnectionService, getInstanceDiscoveryService, getRemoteInvokerRegistry, refreshConnections, setAsyncConnectionService, setInstanceConnectionService, setInstanceDiscoveryService, setRemoteInvokerRegistry, start

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleWorkerInstance

public SimpleWorkerInstance()

Method Details

getInstanceId

public InstanceId getInstanceId()

Description copied from interface: Instance

Gets this instances InstanceId

Specified by:

getInstanceId in interface Instance

Overrides:

getInstanceId in class SimpleInstance

Returns:

the InstanceId

preStart

protected void preStart(Consumer<Exception> exceptionConsumer)

Overrides:

preStart in class SimpleInstance

postStart

protected void postStart(Consumer<Exception> exceptionConsumer)

Overrides:

postStart in class SimpleInstance

preClose

protected void preClose(Consumer<Exception> exceptionConsumer)

Overrides:

preClose in class SimpleInstance

postClose

protected void postClose(Consumer<Exception> exceptionConsumer)

Overrides:

postClose in class SimpleInstance

accessWorkerState

public Worker.Accessor accessWorkerState()

Description copied from interface: Worker

Opens an Worker.Accessor which can be used to read the run-state of this Worker.

Specified by:

accessWorkerState in interface Worker

Returns:

the Worker.Accessor

beginMutation

public Worker.Mutator beginMutation()

Description copied from interface: Worker

Opens a Worker.Mutator which can be used to modify the run-state of this Worker.

Specified by:

beginMutation in interface Worker

Returns:

the Worker.Mutator

getNodeSet

public Set<Node> getNodeSet()

getPersistenceEnvironment

public PersistenceEnvironment getPersistenceEnvironment()

setPersistenceEnvironment

@Inject
public void setPersistenceEnvironment(PersistenceEnvironment persistenceEnvironment)

setNodeSet

@Inject
public void setNodeSet(Set<Node> nodeSet)

getMasterNode

public Node getMasterNode()

setMasterNode

@Inject
public void setMasterNode(@Named("dev.getelements.elements.rt.node.master")
 Node masterNode)

setInstanceId

@Inject
public void setInstanceId(InstanceId instanceId)

Overrides:

setInstanceId in class SimpleInstance

getNodeFactory

public Node.Factory getNodeFactory()

setNodeFactory

@Inject
public void setNodeFactory(Node.Factory nodeFactory)