Class CamundaJobWorker<VariablesDto, CustomHeadersDto>

Type Parameters

Hierarchy

Constructors

constructor

Properties

capacity config currentlyActiveJobCount log logMeta loopHandle? pollInterval restClient

Methods

handleJob poll start stop

Constructors

constructor

Properties

capacity

capacity: number

Private Readonly config

config: CamundaJobWorkerConfig<VariablesDto, CustomHeadersDto>

currentlyActiveJobCount

currentlyActiveJobCount: number = 0

log

log: Logger

logMeta

logMeta: (() => {
    capacity: number;
    currentload: number;
    pollIntervalMs: number;
    type: string;
    worker: string;
})

Type declaration

    • (): {
          capacity: number;
          currentload: number;
          pollIntervalMs: number;
          type: string;
          worker: string;
      }

    • Returns {
          capacity: number;
          currentload: number;
          pollIntervalMs: number;
          type: string;
          worker: string;
      }

      • capacity: number
      • currentload: number
      • pollIntervalMs: number
      • type: string
      • worker: string

Private Optional loopHandle

loopHandle?: Timeout

Private pollInterval

pollInterval: number

Private Readonly restClient

restClient: CamundaRestClient

Methods

Private handleJob

Private poll

start

stop

  • stop(deadlineMs?): Promise<unknown>

  • Stops the Job Worker polling for more jobs. If await this call, and it will return as soon as all currently active jobs are completed. The deadline for all currently active jobs to complete is 30s by default. If the active jobs do not complete by the deadline, this method will throw.

    Parameters

    • deadlineMs: number = 30000

    Returns Promise<unknown>

Settings

Member Visibility

Theme

On This Page

Generated using TypeDoc