Package dev.getelements.elements.remote.jeromq

Class JeroMQNode

java.lang.Object
dev.getelements.elements.remote.jeromq.JeroMQNode
All Implemented Interfaces:
Node
public class JeroMQNode extends Object implements Node

  • Field Details

  • Constructor Details

    • JeroMQNode

      public JeroMQNode()

  • Method Details

    • getName

      public String getName()
      Description copied from interface: Node
      Gets the symbolic name of the node. This can be assigned by the container or assigned in configuration. It should be human readable, and should be unique per Instance. Used just for symbolic naming of the Node and in logging.
      Specified by:
      getName in interface Node
      Returns:
      the name of the node

    • getNodeId

      public NodeId getNodeId()
      Description copied from interface: Node
      Gets the NodeId
      Specified by:
      getNodeId in interface Node
      Returns:
      the NodeId

    • getState

      public NodeState getState()
      Description copied from interface: Node
      Gets the state of the node.
      Specified by:
      getState in interface Node
      Returns:
      the NodeState indicating the state of the node.

    • getOutboundAddr

      public String getOutboundAddr()

    • beginStartup

      public Node.Startup beginStartup()
      Description copied from interface: Node
      Begins the startup process by returning an instance of Node.Startup.
      Specified by:
      beginStartup in interface Node
      Returns:
      the pending Node.Startup object

    • beginShutdown

      public Node.Shutdown beginShutdown()
      Description copied from interface: Node
      Begins the shutdown process.
      Specified by:
      beginShutdown in interface Node
      Returns:
      the Node.Shutdown object

    • getInvocationDispatcher

      public LocalInvocationDispatcher getInvocationDispatcher()

    • setInvocationDispatcher

      @Inject public void setInvocationDispatcher(LocalInvocationDispatcher invocationDispatcher)

    • getPayloadReader

      public PayloadReader getPayloadReader()

    • setPayloadReader

      @Inject public void setPayloadReader(PayloadReader payloadReader)

    • getPayloadWriter

      public PayloadWriter getPayloadWriter()

    • setPayloadWriter

      @Inject public void setPayloadWriter(PayloadWriter payloadWriter)

    • getAsyncConnectionService

      public AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> getAsyncConnectionService()

    • setAsyncConnectionService

      @Inject public void setAsyncConnectionService(AsyncConnectionService<org.zeromq.ZContext,org.zeromq.ZMQ.Socket> asyncConnectionService)

    • setNodeId

      @Inject public void setNodeId(NodeId nodeId)

    • setName

      @Inject public void setName(@Named("dev.getelements.elements.rt.node.name") String name)

    • getMinConnections

      public int getMinConnections()

    • setMinConnections

      @Inject public void setMinConnections(@Named("dev.getelements.elements.remote.jeromq.node.min.connections") int minConnections)

    • getMaxConnections

      public int getMaxConnections()

    • setMaxConnections

      @Inject public void setMaxConnections(@Named("dev.getelements.elements.remote.jeromq.node.max.connections") int maxConnections)

    • getNodeLifecycle

      public NodeLifecycle getNodeLifecycle()

    • setNodeLifecycle

      @Inject public void setNodeLifecycle(NodeLifecycle nodeLifecycle)