summaryrefslogtreecommitdiff
path: root/src/queue
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-04-06 03:42:55 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-04-06 03:42:55 +0900
commit0154e44e1d02829e8f35fa131005448f694e745e (patch)
tree1aed12d3deef69ad7f094ee06b57fdb71180d41f /src/queue
parentRENAME: api --> services (diff)
downloadsharkey-0154e44e1d02829e8f35fa131005448f694e745e.tar.gz
sharkey-0154e44e1d02829e8f35fa131005448f694e745e.tar.bz2
sharkey-0154e44e1d02829e8f35fa131005448f694e745e.zip
Fix bugs
Diffstat (limited to 'src/queue')
-rw-r--r--src/queue/processors/http/index.ts3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/queue/processors/http/index.ts b/src/queue/processors/http/index.ts
index 3d7d941b1a..61d7f9ac94 100644
--- a/src/queue/processors/http/index.ts
+++ b/src/queue/processors/http/index.ts
@@ -12,8 +12,9 @@ export default (job, done) => {
const handler = handlers[job.data.type];
if (handler) {
- handler(job).then(() => done(), done);
+ handler(job, done);
} else {
console.warn(`Unknown job: ${job.data.type}`);
+ done();
}
};