diff --git a/frontend/server/queues/outboundDelivery.ts b/frontend/server/queues/outboundDelivery.ts index 57cb2a3..c7d62a4 100644 --- a/frontend/server/queues/outboundDelivery.ts +++ b/frontend/server/queues/outboundDelivery.ts @@ -99,7 +99,7 @@ export async function enqueueOutboundDelivery(input: OutboundDeliveryJob, opts?: }); return q.add("deliver", { ...input, endpoint }, { - jobId: `omni:${input.omniMessageId}`, + jobId: `omni-${input.omniMessageId}`, attempts: 12, backoff: { type: "exponential", delay: 1000 }, ...opts, diff --git a/omni_outbound/src/queues/outboundDelivery.ts b/omni_outbound/src/queues/outboundDelivery.ts index 70014b3..229be49 100644 --- a/omni_outbound/src/queues/outboundDelivery.ts +++ b/omni_outbound/src/queues/outboundDelivery.ts @@ -98,7 +98,7 @@ export async function enqueueOutboundDelivery(input: OutboundDeliveryJob, opts?: }); return q.add("deliver", { ...input, endpoint }, { - jobId: `omni:${input.omniMessageId}`, + jobId: `omni-${input.omniMessageId}`, attempts: 12, backoff: { type: "exponential", delay: 1000 }, ...opts,