diff options
Diffstat (limited to 'src/queue/index.ts')
| -rw-r--r-- | src/queue/index.ts | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/src/queue/index.ts b/src/queue/index.ts index f90754a561..4aa1dc032d 100644 --- a/src/queue/index.ts +++ b/src/queue/index.ts @@ -1,6 +1,6 @@ import { createQueue } from 'kue'; + import config from '../config'; -import db from './processors/db'; import http from './processors/http'; const queue = createQueue({ @@ -18,17 +18,19 @@ export function createHttp(data) { .backoff({ delay: 16384, type: 'exponential' }); } -export function createDb(data) { - return queue.create('db', data); +export function deliver(user, content, to) { + return createHttp({ + type: 'deliver', + user, + content, + to + }); } -export function process() { - queue.process('db', db); - +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 |