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:
dev.getelements.elements.rt.remote.Instance, Worker, AutoCloseable
public class SimpleWorkerInstance extends dev.getelements.elements.rt.remote.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.

  • Constructor Details

    • SimpleWorkerInstance

      public SimpleWorkerInstance()

  • Method Details

    • getInstanceId

      public dev.getelements.elements.sdk.cluster.id.InstanceId getInstanceId()
      Specified by:
      getInstanceId in interface dev.getelements.elements.rt.remote.Instance
      Overrides:
      getInstanceId in class dev.getelements.elements.rt.remote.SimpleInstance

    • preStart

      protected void preStart(Consumer<Exception> exceptionConsumer)
      Overrides:
      preStart in class dev.getelements.elements.rt.remote.SimpleInstance

    • postStart

      protected void postStart(Consumer<Exception> exceptionConsumer)
      Overrides:
      postStart in class dev.getelements.elements.rt.remote.SimpleInstance

    • preClose

      protected void preClose(Consumer<Exception> exceptionConsumer)
      Overrides:
      preClose in class dev.getelements.elements.rt.remote.SimpleInstance

    • postClose

      protected void postClose(Consumer<Exception> exceptionConsumer)
      Overrides:
      postClose in class dev.getelements.elements.rt.remote.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 dev.getelements.elements.rt.PersistenceEnvironment getPersistenceEnvironment()

    • setPersistenceEnvironment

      @Inject public void setPersistenceEnvironment(dev.getelements.elements.rt.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(dev.getelements.elements.sdk.cluster.id.InstanceId instanceId)
      Overrides:
      setInstanceId in class dev.getelements.elements.rt.remote.SimpleInstance

    • getNodeFactory

      public Node.Factory getNodeFactory()

    • setNodeFactory

      @Inject public void setNodeFactory(Node.Factory nodeFactory)