rabbit-job-queue/org.veupathdb.lib.rabbit.jobs/QueueDispatcher

QueueDispatcher

class QueueDispatcher : QueueWrapper
Content copied to clipboard

Job dispatcher.

Constructors

Link copied to clipboard
fun QueueDispatcher(config: QueueConfig)
Content copied to clipboard
Link copied to clipboard
fun QueueDispatcher(action: QueueConfig.() -> Unit)
Content copied to clipboard

Functions

Link copied to clipboard
fun dispatch(job: JobDispatch)
Content copied to clipboard

Dispatches a new job on the job queue.

Link copied to clipboard
fun onError(fn: ErrorHandler)
Content copied to clipboard

Registers a callback to be executed on job failure notification.

Link copied to clipboard
fun onSuccess(fn: SuccessHandler)
Content copied to clipboard

Registers a callback to be executed on job success notification.