conveyor-mq

__namedParameters: object

• queue: string

• redisConfig: object

  • host: string

  • port: number

__namedParameters: object

• queue: string

• redisConfig: object

  • host: string

  • port: number

__namedParameters: object

• defaultStallTimeout: number

• delayedTasksCheckInterval: number

• queue: string

• redisConfig: object

  • host: string

  • port: number

• stalledCheckInterval: number

__namedParameters: object

• autoStart: boolean

• concurrency: number

• defaultStallTimeout: number

• defaultTaskAcknowledgementInterval: undefined | number

• getRetryDelay: undefined | function

• handler: function

  • • (__namedParameters: object): any

    • Parameters

      • __namedParameters: object

        • task: Task

        • updateTask: function

          • • (taskUpdateData: Partial<Task>): Promise<Task>

            • Parameters

              • taskUpdateData: Partial<Task>

              Returns Promise<Task>

        • updateTaskProgress: function

          • • (progress: any): Promise<Task>

            • Parameters

              • progress: any

              Returns Promise<Task>

      Returns any

• idleTimeout: number

• onHandlerError: undefined | function

• onIdle: undefined | function

• onReady: undefined | function

• onTaskError: undefined | function

• onTaskFailed: undefined | function

• onTaskSuccess: undefined | function

• queue: string

• redisConfig: object

  • host: string

  • port: number

• removeOnFailed: boolean

• removeOnSuccess: boolean

workerString: string

__namedParameters: object

• client: Redis

• queue: string

__namedParameters: object

• multi: Pipeline

• queue: string

• remove: undefined | false | true

• tasksAndErrors: object[]

worker: Worker