QueueWorker

class QueueWorker : QueueWrapper

Job executor end of the job queue.

Constructors

Link copied to clipboard
fun QueueWorker(config: QueueConfig)

Instantiates a new QueueWorker based on the given configuration.

Link copied to clipboard
fun QueueWorker(action: QueueConfig.() -> Unit)

Instantiates a new QueueWorker using the given action to configure the RabbitMQ connections.

Functions

Link copied to clipboard
fun onJob(fn: JobHandler)

Registers a callback to be executed when a new job is submitted to the queue.

Link copied to clipboard
fun sendError(err: ErrorNotification)

Sends an error notification to the job dispatcher to alert it that a submitted job has failed.

Link copied to clipboard
fun sendSuccess(msg: SuccessNotification)

Sends a success notification to the job dispatcher to alert it that a submitted job has succeeded.