Class CamundaJobWorker<VariablesDto, CustomHeadersDto>

constructor

• new CamundaJobWorker<
      VariablesDto extends LosslessDto,
      CustomHeadersDto extends LosslessDto,
  >(
      config: CamundaJobWorkerConfig<VariablesDto, CustomHeadersDto>,
      restClient: CamundaRestClient,
  ): CamundaJobWorker<VariablesDto, CustomHeadersDto>

  Type Parameters

  • VariablesDto extends LosslessDto
  • CustomHeadersDto extends LosslessDto

  Parameters

  • config: CamundaJobWorkerConfig<VariablesDto, CustomHeadersDto>
  • restClient: CamundaRestClient

  Returns CamundaJobWorker<VariablesDto, CustomHeadersDto>

capacity

currentlyActiveJobCount

log

logMeta

stopping

start

• start(): void

  Returns void

stop

• stop(deadlineMs?: number): 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>