natty
/
calckey
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix bug

This commit is contained in:
syuilo 2018-04-22 07:50:09 +09:00
parent 40849a5aa8
commit 7ee0cad010
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/queue/index.ts
View File

@ -14,6 +14,7 @@ const queue = createQueue({
export function createHttp(data) { export function createHttp(data) {
return queue return queue
.create('http', data) .create('http', data)
.removeOnComplete(true)
.events(false) .events(false)
.attempts(8) .attempts(8)
.backoff({ delay: 16384, type: 'exponential' }); .backoff({ delay: 16384, type: 'exponential' });
@ -26,7 +27,7 @@ export function deliver(user, content, to) {
user, user,
content, content,
to to
}).removeOnComplete(true).save(); }).save();
} }
export default function() { export default function() {