Requeue messages on the server as well
parent
0c118f322f
commit
b4ab56c712
|
@ -22,7 +22,7 @@ export async function reindexSpace() {
|
|||
// Now let's wait for the processing to finish
|
||||
let queueStats = await mq.getQueueStats("indexQueue");
|
||||
while (queueStats.queued > 0 || queueStats.processing > 0) {
|
||||
sleep(1000);
|
||||
await sleep(500);
|
||||
queueStats = await mq.getQueueStats("indexQueue");
|
||||
}
|
||||
// And notify the user
|
||||
|
|
|
@ -68,6 +68,11 @@ export class ServerSystem {
|
|||
|
||||
const mq = new DataStoreMQ(this.ds);
|
||||
|
||||
setInterval(() => {
|
||||
// Timeout after 5s, retries 3 times, otherwise drops the message (no DLQ)
|
||||
mq.requeueTimeouts(5000, 3, true).catch(console.error);
|
||||
}, 20000); // Look to requeue every 20s
|
||||
|
||||
const plugNamespaceHook = new PlugNamespaceHook();
|
||||
this.system.addHook(plugNamespaceHook);
|
||||
|
||||
|
@ -154,6 +159,7 @@ export class ServerSystem {
|
|||
"reindexSpace",
|
||||
[],
|
||||
).then(() => {
|
||||
console.log("Initial index completed!");
|
||||
this.ds.set(["$initialIndexDone"], true);
|
||||
}).catch(console.error);
|
||||
if (awaitIndex) {
|
||||
|
|
|
@ -100,7 +100,7 @@ function loadJsByUrl(url) {
|
|||
}
|
||||
</script>
|
||||
<!-- Load SB's own CSS here too -->
|
||||
<link rel="stylesheet" href="/.client/main.css" />
|
||||
<link rel="stylesheet" href="/.client/main.css">
|
||||
<style>
|
||||
html,
|
||||
body {
|
||||
|
|
Loading…
Reference in New Issue