1234567891011121314151617 |
- import * as Bull from 'bull'
- import { logger } from '../../../helpers/logger'
- import { Emailer } from '../../emailer'
- import { EmailPayload } from '@shared/models'
- async function processEmail (job: Bull.Job) {
- const payload = job.data as EmailPayload
- logger.info('Processing email in job %d.', job.id)
- return Emailer.Instance.sendMail(payload)
- }
- // ---------------------------------------------------------------------------
- export {
- processEmail
- }
|