Kue - redis task queue

kue.js

import * as kue from "kue";
import config from "../config/config";

export const Queue = kue.createQueue({
    prefix: "q",
    redis: config.redis.host
});

export const ProcessQueue = kue.createQueue();

ProcessQueue.process("test", (job, done) => {
    console.log("#==================================================#");
    console.log(job.data);
    console.log("#==================================================#");
    done(null, {
        success: "much",
        process: "very",
        resolution: "wow"
    });
});

Queue
    .create("test", {
        title: "test",
        to: "me@lol.com",
        user: "me",
        redis: config.redis.host
    })
    .on("job enqueue", (id, type) => {
        console.log( "Job %s got queued of type %s", id, type );
    })
    .on("complete", (result) => {
        console.log("Job completed with data ", result);
    })
    .on("failed attempt", () => {
        console.warn("Job failed attempt");
    })
    .on("failed", () => {
        console.error("Job failed utterly");
    })
    .on("progress", (progress, data) => {
        console.log(`\r  job #someid (this is the test) ${progress}% complete with data `, data );
    })
    .save((error) => {
        if (error) {
            console.error(error);
        } else {
            console.log("job saved");
        }
    });