diff --git a/src/activitypub/index.js b/src/activitypub/index.js
index 1da83850d9..8b997e81d7 100644
--- a/src/activitypub/index.js
+++ b/src/activitypub/index.js
@@ -464,7 +464,10 @@ async function retryFailedMessages() {
 			}]);
 		}
 	}));
+
 	await Promise.all([
+		db.sortedSetAddBulk(retryQueueAdd),
+		db.setObjectBulk(retryQueuedSet),
 		db.sortedSetRemove('ap:retry:queue', queueIdsToRemove),
 		db.deleteAll(queueIdsToRemove.map(id => `ap:retry:queue:${id}`)),
 	]);