Package com.tibco.ep.testing.framework

Class MultiNodeWorker

java.lang.Object
com.tibco.ep.testing.framework.MultiNodeWorker
@Managed @Key(fields="nodeName",name="ByNodeName",unique=false) @Key(fields={"nodeName","source"},name="ByNodeNameSource",unique=true) class MultiNodeWorker extends Object
Multi-node worker

  • Field Details

    • state

      String state
      Work state

  • Constructor Details

    • MultiNodeWorker

      MultiNodeWorker(String nodeName, String source)
      Constructor
      Parameters:
      nodeName - node name
      source - source

  • Method Details

    • getOrCreate

      static MultiNodeWorker getOrCreate(String nodeName, String source)
      Get or create worker
      Parameters:
      nodeName - node name
      source - source
      Returns:
      worker

    • getOrCreateLastAgreedState

      static MultiNodeWorker getOrCreateLastAgreedState()
      Get or create last agreed state worker
      Returns:
      worker

    • getCurrentLastAgreedState

      static MultiNodeWorker getCurrentLastAgreedState()
      Get current last agreed state worker
      Returns:
      worker

    • getByNodeNameSource

      static MultiNodeWorker getByNodeNameSource(String nodeName, String source, com.kabira.platform.QueryScope scope, com.kabira.platform.LockMode lockMode)
      Get worker by source
      Parameters:
      nodeName - node name
      source - source
      scope - query scope
      lockMode - lock mode
      Returns:
      worker

    • getByNodeName

      static Iterable<MultiNodeWorker> getByNodeName(String nodeName, com.kabira.platform.QueryScope scope)
      Get by node name
      Parameters:
      nodeName - node name
      scope - query scope
      Returns:
      workers

    • getState

      String getState()
      Get state
      Returns:
      state

    • setState

      void setState(String state)
      Set state
      Parameters:
      state - state

    • getSource

      String getSource()
      Get source
      Returns:
      source

    • toString

      public String toString()
      Overrides:
      toString in class Object