Package com.github.workerframework.api

Interface WorkerQueueProvider

All Known Implementing Classes:
RabbitWorkerQueueProvider
public interface WorkerQueueProvider
Boilerplate for retrieving a WorkerQueue implementation.

  • Method Details

    • getWorkerQueue

      ManagedWorkerQueue getWorkerQueue(ConfigurationSource configurationSource, int maxTasks) throws QueueException
      Create a new WorkerQueue instance.
      Parameters:
      configurationSource - used for configuring the WorkerQueue
      maxTasks - the maximum number of tasks the worker can perform at once
      Returns:
      a new WorkerQueue instance
      Throws:
      QueueException - if a WorkerQueue could not be created