Interface QueueEventsListenerPro

Hierarchy

QueueEventsListener
- QueueEventsListenerPro

Index

Properties

active added cleaned completed delayed drained error failed groups:paused groups:resumed ioredis:close paused progress removed resumed retries-exhausted stalled waiting waiting-children

Properties

active

active: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'active' event.
  
  This event is triggered when a job enters the 'active' state.
  Parameters
  - args: {
    jobId: string;
    prev?: string;
    }
    - jobId: string
    - Optional prev?: string
  - id: string
  Returns void

added

added: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'added' event.
  
  This event is triggered when a job is created.
  Parameters
  - args: {
        data: string;
        jobId: string;
        name: string;
        opts: string;
    }
    - data: string
    - jobId: string
    - name: string
    - opts: string
  - id: string
  Returns void

cleaned

cleaned: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'cleaned' event.
  
  This event is triggered when a cleaned method is triggered.
  Parameters
  - args: {
    count: string;
    }
    - count: string
  - id: string
  Returns void

completed

completed: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'completed' event.
  
  This event is triggered when a job has successfully completed.
  Parameters
  - args: {
        jobId: string;
        prev?: string;
        returnvalue: string;
    }
    - jobId: string
    - Optional prev?: string
    - returnvalue: string
  - id: string
  Returns void

delayed

delayed: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'delayed' event.
  
  This event is triggered when a job is delayed.
  Parameters
  - args: {
    delay: number;
    jobId: string;
    }
    - delay: number
    - jobId: string
  - id: string
  Returns void

drained

drained: ((id) => void)

Type declaration

- (id): void
- Listen to 'drained' event.
  
  This event is triggered when the queue has drained the waiting list. Note that there could still be delayed jobs waiting their timers to expire and this event will still be triggered as long as the waiting list has emptied.
  Parameters
  - id: string
  Returns void

error

error: ((args) => void)

Type declaration

- (args): void
- Listen to 'error' event.
  
  This event is triggered when an exception is thrown.
  Parameters
  - args: Error
  Returns void

failed

failed: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'failed' event.
  
  This event is triggered when a job has thrown an exception.
  Parameters
  - args: {
        failedReason: string;
        jobId: string;
        prev?: string;
    }
    - failedReason: string
    - jobId: string
    - Optional prev?: string
  - id: string
  Returns void

groups:paused

groups:paused: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'groups:paused' event.
  
  This event is triggered when a group is paused.
  Parameters
  - args: {
    groupId: string;
    }
    - groupId: string
  - id: string
  Returns void

groups:resumed

groups:resumed: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'groups:resumed' event.
  
  This event is triggered when a group is resumed.
  Parameters
  - args: {
    groupId: string;
    }
    - groupId: string
  - id: string
  Returns void

ioredis:close

ioredis:close: (() => void)

Type declaration

- (): void
- Listen to 'ioredis:close' event.
  
  This event is triggered when ioredis is closed.
  
  Returns void

paused

paused: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'paused' event.
  
  This event is triggered when a queue is paused.
  Parameters
  - args: {}
  - id: string
  Returns void

progress

progress: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'progress' event.
  
  This event is triggered when a job updates it progress, i.e. the Job##updateProgress() method is called. This is useful to notify progress or any other data from within a processor to the rest of the world.
  Parameters
  - args: {
    data: number | object;
    jobId: string;
    }
    - data: number | object
    - jobId: string
  - id: string
  Returns void

removed

removed: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'removed' event.
  
  This event is triggered when a job has been manually removed from the queue.
  Parameters
  - args: {
    jobId: string;
    prev: string;
    }
    - jobId: string
    - prev: string
  - id: string
  Returns void

resumed

resumed: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'resumed' event.
  
  This event is triggered when a queue is resumed.
  Parameters
  - args: {}
  - id: string
  Returns void

retries-exhausted

retries-exhausted: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'retries-exhausted' event.
  
  This event is triggered when a job has retried the maximum attempts.
  Parameters
  - args: {
    attemptsMade: string;
    jobId: string;
    }
    - attemptsMade: string
    - jobId: string
  - id: string
  Returns void

stalled

stalled: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'stalled' event.
  
  This event is triggered when a job has been moved from 'active' back to 'waiting'/'failed' due to the processor not being able to renew the lock on the said job.
  Parameters
  - args: {
    jobId: string;
    }
    - jobId: string
  - id: string
  Returns void

waiting

waiting: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'waiting' event.
  
  This event is triggered when a job enters the 'waiting' state.
  Parameters
  - args: {
    jobId: string;
    prev?: string;
    }
    - jobId: string
    - Optional prev?: string
  - id: string
  Returns void

waiting-children

waiting-children: ((args, id) => void)

Type declaration

- (args, id): void
- Listen to 'waiting-children' event.
  
  This event is triggered when a job enters the 'waiting-children' state.
  Parameters
  - args: {
    jobId: string;
    }
    - jobId: string
  - id: string
  Returns void

Interface QueueEventsListenerPro

Hierarchy

Index

Properties

Properties

active

Type declaration

Parameters

args: { jobId: string; prev?: string; }

jobId: string

Optional prev?: string

id: string

Returns void

added

Type declaration

Parameters

args: { data: string; jobId: string; name: string; opts: string; }

data: string

jobId: string

name: string

opts: string

id: string

Returns void

cleaned

Type declaration

Parameters

args: { count: string; }

count: string

id: string

Returns void

completed

Type declaration

Parameters

args: { jobId: string; prev?: string; returnvalue: string; }

jobId: string

Optional prev?: string

returnvalue: string

id: string

Returns void

delayed

Type declaration

Parameters

args: { delay: number; jobId: string; }

delay: number

jobId: string

id: string

Returns void

drained

Type declaration

Parameters

id: string

Returns void

error

Type declaration

Parameters

args: Error

Returns void

failed

Type declaration

Parameters

args: { failedReason: string; jobId: string; prev?: string; }

failedReason: string

jobId: string

Optional prev?: string

id: string

Returns void

groups:paused

Type declaration

Parameters

args: { groupId: string; }

groupId: string

id: string

Returns void

groups:resumed

Type declaration

Parameters

args: { groupId: string; }

groupId: string

id: string

Returns void

args: {
jobId: string;
prev?: string;
}

`Optional` prev?: string

args: {
data: string;
jobId: string;
name: string;
opts: string;
}

args: {
count: string;
}

args: {
jobId: string;
prev?: string;
returnvalue: string;
}

`Optional` prev?: string

args: {
delay: number;
jobId: string;
}

args: {
failedReason: string;
jobId: string;
prev?: string;
}

`Optional` prev?: string

args: {
groupId: string;
}

args: {
groupId: string;
}

args: {
data: number | object;
jobId: string;
}

args: {
jobId: string;
prev: string;
}

args: {
attemptsMade: string;
jobId: string;
}

args: {
jobId: string;
}

args: {
jobId: string;
prev?: string;
}

`Optional` prev?: string

args: {
jobId: string;
}