Class ChildProcessor

ChildProcessor

This class acts as the interface between a child process and it parent process so that jobs can be processed in different processes.

Hierarchy

ChildProcessor

Index

Constructors

Properties

currentJobPromise processor status?

Methods

init start stop waitForCurrentJobAndExit

Constructors

constructor

new ChildProcessor(send): ChildProcessor
Parameters
- send: ((msg) => Promise<void>)
  - - (msg): Promise<void>
    - Parameters
      
      msg: any
      
      Returns Promise<void>
Returns ChildProcessor
- Defined in bullmq/dist/esm/classes/child-processor.d.ts:20

Properties

currentJobPromise

currentJobPromise: Promise<unknown>

processor

processor: any

`Optional` status

status?: ChildStatus

Methods

init

init(processorFile): Promise<void>
Parameters
- processorFile: string
Returns Promise<void>
- Defined in bullmq/dist/esm/classes/child-processor.d.ts:21

start

start(jobJson, token?): Promise<void>
Parameters
- jobJson: JobJson
- Optional token: string
Returns Promise<void>
- Defined in bullmq/dist/esm/classes/child-processor.d.ts:22

stop

stop(): Promise<void>
Returns Promise<void>
- Defined in bullmq/dist/esm/classes/child-processor.d.ts:23

waitForCurrentJobAndExit

waitForCurrentJobAndExit(): Promise<void>
Returns Promise<void>
- Defined in bullmq/dist/esm/classes/child-processor.d.ts:24

Generated using TypeDoc