Class ZBStreamWorker

Implements

IZBJobWorker

Index

Constructors

Methods

close debug error log makeCompleteHandlers streamJobs

Constructors

constructor

new ZBStreamWorker(
    __namedParameters: {
        grpcClient: ZBGrpc;
        log: StatefulLogInterceptor;
        zbClient: ZeebeGrpcClient;
    },
): ZBStreamWorker
Parameters
- __namedParameters: { grpcClient: ZBGrpc; log: StatefulLogInterceptor; zbClient: ZeebeGrpcClient }
Returns ZBStreamWorker
- Defined in src/zeebe/lib/ZBStreamWorker.ts:27

Methods

close

close(): Promise<void>
Returns Promise<void>
- Defined in src/zeebe/lib/ZBStreamWorker.ts:103

debug

debug(msg: JSON): void
Parameters
- msg: JSON
Returns void
Implementation of IZBJobWorker.debug
- Defined in src/zeebe/lib/ZBStreamWorker.ts:116

error

error(msg: JSON): void
Parameters
- msg: JSON
Returns void
Implementation of IZBJobWorker.error
- Defined in src/zeebe/lib/ZBStreamWorker.ts:120

log

log(msg: JSON): void
Parameters
- msg: JSON
Returns void
Implementation of IZBJobWorker.log
- Defined in src/zeebe/lib/ZBStreamWorker.ts:112

`Protected`makeCompleteHandlers

makeCompleteHandlers<T>(
thisJob: Job,
taskType: string,
): JobCompletionInterface<T>
Type Parameters
- T
Parameters
- thisJob: Job
- taskType: string
Returns JobCompletionInterface<T>
- Defined in src/zeebe/lib/ZBStreamWorker.ts:124

streamJobs

streamJobs<WorkerInputVariables, CustomHeaderShape, WorkerOutputVariables>(
    req: StreamActivatedJobsRequest & {
        customHeadersDto: new (...args: any[]) => Readonly<CustomHeaderShape>;
        inputVariableDto: new (...args: any[]) => Readonly<WorkerInputVariables>;
        taskHandler: ZBWorkerTaskHandler<
            WorkerInputVariables,
            CustomHeaderShape,
            WorkerOutputVariables,
        >;
    },
): Promise<{ close: () => void }>
Type Parameters
- WorkerInputVariables
- CustomHeaderShape
- WorkerOutputVariables
Parameters
- req: StreamActivatedJobsRequest & {
      customHeadersDto: new (...args: any[]) => Readonly<CustomHeaderShape>;
      inputVariableDto: new (...args: any[]) => Readonly<WorkerInputVariables>;
      taskHandler: ZBWorkerTaskHandler<
          WorkerInputVariables,
          CustomHeaderShape,
          WorkerOutputVariables,
      >;
  }
Returns Promise<{ close: () => void }>
- Defined in src/zeebe/lib/ZBStreamWorker.ts:45