chore(queue-worker): 🔧 Add configurable queue processing registration system

Co-Authored-By: Lilith Autocommit <noreply@atlilith.com>
This commit is contained in:
Lilith 2026-02-20 23:42:06 -08:00
parent 4deab52199
commit a93d72754d
2 changed files with 22 additions and 0 deletions

View file

@ -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',

View file

@ -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',