diff options
| author | Chocobozzz <me@florianbigard.com> | 2018-07-10 17:02:20 +0200 |
|---|---|---|
| committer | Chocobozzz <me@florianbigard.com> | 2018-07-11 14:00:17 +0200 |
| commit | 94831479f5facff9469540a3d49dd347b88bdf5a (patch) | |
| tree | 4e8990fc4fded913952c732b6466b15fc52ab06d /server/lib/job-queue/handlers/email.ts | |
| parent | 2cdf27bae6acfaa0b99bb07555edc57f48b8bc43 (diff) | |
| download | PeerTube-94831479f5facff9469540a3d49dd347b88bdf5a.tar.gz PeerTube-94831479f5facff9469540a3d49dd347b88bdf5a.tar.zst PeerTube-94831479f5facff9469540a3d49dd347b88bdf5a.zip | |
Migrate to bull
Diffstat (limited to 'server/lib/job-queue/handlers/email.ts')
| -rw-r--r-- | server/lib/job-queue/handlers/email.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/server/lib/job-queue/handlers/email.ts b/server/lib/job-queue/handlers/email.ts index 9d7686116..73d98ae54 100644 --- a/server/lib/job-queue/handlers/email.ts +++ b/server/lib/job-queue/handlers/email.ts | |||
| @@ -1,4 +1,4 @@ | |||
| 1 | import * as kue from 'kue' | 1 | import * as Bull from 'bull' |
| 2 | import { logger } from '../../../helpers/logger' | 2 | import { logger } from '../../../helpers/logger' |
| 3 | import { Emailer } from '../../emailer' | 3 | import { Emailer } from '../../emailer' |
| 4 | 4 | ||
| @@ -8,7 +8,7 @@ export type EmailPayload = { | |||
| 8 | text: string | 8 | text: string |
| 9 | } | 9 | } |
| 10 | 10 | ||
| 11 | async function processEmail (job: kue.Job) { | 11 | async function processEmail (job: Bull.Job) { |
| 12 | const payload = job.data as EmailPayload | 12 | const payload = job.data as EmailPayload |
| 13 | logger.info('Processing email in job %d.', job.id) | 13 | logger.info('Processing email in job %d.', job.id) |
| 14 | 14 | ||