Add queue timeout (#7519)

This commit is contained in:
MeiMei 2021-05-19 16:12:31 +09:00 committed by GitHub
parent 3ac582472e
commit 634f4eeb16

View file

@ -71,6 +71,7 @@ export function deliver(user: ThinUser, content: unknown, to: string | null) {
return deliverQueue.add(data, { return deliverQueue.add(data, {
attempts: config.deliverJobMaxAttempts || 12, attempts: config.deliverJobMaxAttempts || 12,
timeout: 1 * 60 * 1000, // 1min
backoff: { backoff: {
type: 'exponential', type: 'exponential',
delay: 60 * 1000 delay: 60 * 1000
@ -88,6 +89,7 @@ export function inbox(activity: IActivity, signature: httpSignature.IParsedSigna
return inboxQueue.add(data, { return inboxQueue.add(data, {
attempts: config.inboxJobMaxAttempts || 8, attempts: config.inboxJobMaxAttempts || 8,
timeout: 5 * 60 * 1000, // 5min
backoff: { backoff: {
type: 'exponential', type: 'exponential',
delay: 60 * 1000 delay: 60 * 1000