paricafe/src/queue/index.ts

import { createQueue } from 'kue';

import config from '../config';
import http from './processors/http';
import { ILocalUser } from '../models/user';

const queue = createQueue({
	redis: {
		port: config.redis.port,
		host: config.redis.host,
		auth: config.redis.pass
	}
});

process.once('SIGTERM', () => {
	queue.shutdown(5000, (err: any) => {
		console.log('Kue shutdown: ', err || '');
		process.exit(0);
	});
});

export function createHttp(data: any) {
	return queue
		.create('http', data)
		.removeOnComplete(true)
		.events(false)
		.attempts(8)
		.backoff({ delay: 16384, type: 'exponential' });
}

export function deliver(user: ILocalUser, content: any, to: any) {
	createHttp({
		title: 'deliver',
		type: 'deliver',
		user,
		content,
		to
	}).save();
}

export default function() {
	/*
		256 is the default concurrency limit of Mozilla Firefox and Google
		Chromium.
		a8af215e691f3a2205a3758d2d96e9d328e100ff - chromium/src.git - Git at Google
		https://chromium.googlesource.com/chromium/src.git/+/a8af215e691f3a2205a3758d2d96e9d328e100ff
		Network.http.max-connections - MozillaZine Knowledge Base
		http://kb.mozillazine.org/Network.http.max-connections
	*/
	//queue.process('http', 256, http);
	queue.process('http', 128, http);
}