diff --git a/src/activitypub/index.js b/src/activitypub/index.js index fac6a92ed8..1da83850d9 100644 --- a/src/activitypub/index.js +++ b/src/activitypub/index.js @@ -409,7 +409,7 @@ ActivityPub.send = async (type, id, targets, payload) => { await Promise.all(inboxBatch.map(async (uri) => { const ok = await sendMessage(uri, id, type, payload); if (!ok) { - const queueId = `${type}:${id}:${new URL(uri).hostname}`; + const queueId = `${payload.type}:${payload.id}:${new URL(uri).hostname}`; const nextTryOn = Date.now() + oneMinute; retryQueueAdd.push(['ap:retry:queue', nextTryOn, queueId]); retryQueuedSet.push([`ap:retry:queue:${queueId}`, {