diff --git a/server/notifications/queues/appQueue.js b/server/notifications/queues/appQueue.js index 1f198698c..b376b2cf6 100644 --- a/server/notifications/queues/appQueue.js +++ b/server/notifications/queues/appQueue.js @@ -92,7 +92,7 @@ const loadAppQueue = async ({ pubClient, logger, redisHelpers, ioRedis }) => { "consolidate-notifications", { jobId, recipients }, { - jobId: `consolidate:${jobId}`, + jobId: `consolidate-${jobId}`, delay: APP_CONSOLIDATION_DELAY, attempts: 3, backoff: LOCK_EXPIRATION @@ -288,7 +288,7 @@ const dispatchAppsToQueue = async ({ appsToDispatch }) => { await appQueue.add( "add-notification", { jobId, bodyShopId, key, variables, recipients, body, jobRoNumber }, - { jobId: `${jobId}:${Date.now()}` } + { jobId: `${jobId}-${Date.now()}` } ); devDebugLogger(`Added notification to queue for jobId ${jobId} with ${recipients.length} recipients`); } diff --git a/server/notifications/queues/emailQueue.js b/server/notifications/queues/emailQueue.js index 7d965cb69..a5ad8a530 100644 --- a/server/notifications/queues/emailQueue.js +++ b/server/notifications/queues/emailQueue.js @@ -86,7 +86,7 @@ const loadEmailQueue = async ({ pubClient, logger }) => { "consolidate-emails", { jobId, jobRoNumber, bodyShopName, bodyShopTimezone }, { - jobId: `consolidate:${jobId}`, + jobId: `consolidate-${jobId}`, delay: EMAIL_CONSOLIDATION_DELAY, attempts: 3, backoff: LOCK_EXPIRATION @@ -252,7 +252,7 @@ const dispatchEmailsToQueue = async ({ emailsToDispatch, logger }) => { await emailAddQueue.add( "add-email-notification", { jobId, jobRoNumber, bodyShopName, bodyShopTimezone, body, recipients }, - { jobId: `${jobId}:${Date.now()}` } + { jobId: `${jobId}-${Date.now()}` } ); devDebugLogger(`Added email notification to queue for jobId ${jobId} with ${recipients.length} recipients`); }