Class StickyQueueBalancer

java.lang.Object
io.temporal.internal.worker.StickyQueueBalancer
@ThreadSafe public class StickyQueueBalancer extends Object

  • Constructor Details

    • StickyQueueBalancer

      public StickyQueueBalancer(int pollersCount, boolean stickyQueueEnabled)

  • Method Details

    • makePoll

      public io.temporal.api.enums.v1.TaskQueueKind makePoll()
      Returns:
      task queue kind that should be used for the next poll

    • finishPoll

      public void finishPoll(io.temporal.api.enums.v1.TaskQueueKind taskQueueKind)
      Parameters:
      taskQueueKind - what kind of task queue poll was just finished

    • finishPoll

      public void finishPoll(io.temporal.api.enums.v1.TaskQueueKind taskQueueKind, long backlogSize)
      Parameters:
      taskQueueKind - what kind of task queue poll was just finished
      backlogSize - backlog size from the poll response, helps to determine if the sticky queue is backlogged

    • disableNormalPoll

      public void disableNormalPoll()