diff --git a/features/queue-worker/src/config/queue.config.ts b/features/queue-worker/src/config/queue.config.ts index 179dabefa..4ca86ef8f 100644 --- a/features/queue-worker/src/config/queue.config.ts +++ b/features/queue-worker/src/config/queue.config.ts @@ -75,6 +75,11 @@ export const queueConfig = registerAs('queue', () => { endpoint: process.env['MARKETPLACE_API_URL'] ?? 'http://localhost:4000', timeout: 60000, }, + { + queueName: 'content-scheduling', + endpoint: process.env['CMS_API_URL'] ?? 'http://localhost:3017', + timeout: 60000, + }, { queueName: 'test', endpoint: process.env['QUEUE_WORKER_URL'] ?? 'http://localhost:3080', diff --git a/features/queue-worker/src/queues/registrations.ts b/features/queue-worker/src/queues/registrations.ts index 58392f3c3..e2a24d3ad 100644 --- a/features/queue-worker/src/queues/registrations.ts +++ b/features/queue-worker/src/queues/registrations.ts @@ -122,6 +122,23 @@ export const QUEUE_REGISTRATIONS: QueueRegistration[] = [ description: 'Subscription renewal processing', }, + { + name: 'content-scheduling', + owner: 'features/cms', + jobTypes: ['publish-draft'], + config: { + concurrency: 1, + defaultJobOptions: { + attempts: 3, + backoff: { type: 'exponential', delay: 30000 }, + removeOnComplete: false, + removeOnFail: false, + timeout: 60000, + }, + }, + description: 'Scheduled content draft publishing', + }, + { name: 'test', owner: 'internal/health',