Optional connectionOptional debugEnable debug tracking
Optional failIf a handler throws an unhandled exception, if this is set true, the process will be failed. Defaults to false.
Optional fetchConstrain payload to these keys only.
Optional idA custom id for the worker. If none is supplied, a UUID will be generated.
Optional jobThe minimum amount of jobs to fetch. The worker will request more jobs only when it has capacity for this many jobs. Defaults to 0, meaning the worker will fetch more jobs as soon as it as any capacity.
Optional logOptional loglevelA log level if you want it to differ from the ZBClient
Optional longA custom longpoll timeout. By default long polling is every 30 seconds.
Optional maxMax concurrent tasks for this worker. Default 32.
Optional onThis handler is called when the worker cannot connect to the broker, or loses its connection.
Optional onThis handler is called when the worker cannot connect to the broker, or loses its connection.
Optional onThis handler is called when the worker (re)establishes its connection to the broker
Optional pollPoll Interval in ms. Default 100.
Optional stdoutAn implementation of the ZBCustomLogger interface for logging
A job handler - this must return a job action - e.g.: job.complete(), job.error() - in all code paths.
The task type that this worker will request jobs for.
Optional timeoutMax 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
Generated using TypeDoc
If your Grpc connection jitters, this is the window before the connectionError