Enable debug tracking
If a handler throws an unhandled exception, if this is set true, the process will be failed. Defaults to false.
Constrain payload to these keys only.
A custom id for the worker. If none is supplied, a UUID will be generated.
The max timeout in seconds to wait for a batch to populate. If there are less than minJobBatchSize
jobs
available when this timeout is reached, all currently batched jobs will be processed, regardless.
You should set this higher than the worker timeout, to avoid batched jobs timing out before they are executed.
The minimum amount of jobs to batch before calling the job handler.
A log level if you want it to differ from the ZBClient
A custom longpoll timeout. By default long polling is every 30 seconds.
Max concurrent tasks for this worker. Default 32.
This handler is called when the worker cannot connect to the broker, or loses its connection.
Poll Interval in ms. Default 100.
An implementation of the ZBCustomLogger interface for logging
A job handler - this must return an array of job actions (eg: job.complete(..), job.error(..)) in all code paths.
The task type that this worker will request jobs for.
Max seconds to allow before time out of a job given to this worker. Default: 30s. The broker checks deadline timeouts every 30 seconds, so an
This handler is called when the worker cannot connect to the broker, or loses its connection.
This handler is called when the worker (re)establishes its connection to the broker
Generated using TypeDoc
If your Grpc connection jitters, this is the window before the connectionError