Field Detail

• DEFAULT_POLL_MILLIS

  public static final int DEFAULT_POLL_MILLIS

  Since:

  3.2

  See Also:

  Constant Field Values

Constructor Detail

• QueueWorker

  public QueueWorker()

Method Detail

• getPollMillis

  public long getPollMillis()

• setPollMillis

  public void setPollMillis​(long pollMillis)

• clearQueue

  public void clearQueue()

  Since:

  3.0

• addWork

  public boolean addWork​(E element)

• work

  protected void work​(Worker.WorkContext context)
               throws java.lang.Exception

  Specified by:

  work in class Worker

  Throws:

  java.lang.Exception

• work

  protected abstract void work​(Worker.WorkContext context,
                               E element)

• noWork

  protected void noWork​(Worker.WorkContext context)

  Since:

  3.3

• createQueue

  protected java.util.concurrent.BlockingQueue<E> createQueue()

• doRemainingWorkBeforeDeactivate

  protected boolean doRemainingWorkBeforeDeactivate()

  Since:

  3.1

• doDeactivate

  protected void doDeactivate()
                       throws java.lang.Exception

  Overrides:

  doDeactivate in class Worker

  Throws:

  java.lang.Exception