The Job Protocol#

Jobs are defined by the Job and JobData protocols.

Modeling a JobData object#

import Foundation
import Jobs
import Vapor

struct EmailJobContext: JobData {
    let to: String
    let from: String
    let message: String
}

Modeling a Job object:#

import Foundation
import Jobs 
import Vapor 

struct EmailJob: Job {
    let emailService: EmailService
    
    func dequeue(_ context: JobContext, _ data: EmailJobContext) -> EventLoopFuture<Void> {
        return emailService.sendEmail(to: data.to, subject: data.subject, content: data.message)
    }
    
    func error(_ context: JobContext, _ error: Error, _ data: EmailJobContext) -> EventLoopFuture<Void> {
        // If you don't want to handle errors you can simply return a future. You can also omit this function entirely. 
        return context.eventLoop.future()
    }
}

dequeue and error are not throwing methods - in order to return an error from the function you must use worker.future(error: myErrorHere).