diff --git a/services/mam-api/src/routes/jobs.js b/services/mam-api/src/routes/jobs.js index 4718b31..9d0c7d5 100644 --- a/services/mam-api/src/routes/jobs.js +++ b/services/mam-api/src/routes/jobs.js @@ -9,11 +9,17 @@ const router = express.Router(); router.use(requireAuth); // Initialize BullMQ queue for conform jobs +const parseRedisUrl = (url) => { + try { + const parsed = new URL(url); + return { host: parsed.hostname, port: parseInt(parsed.port, 10) || 6379 }; + } catch { + return { host: 'localhost', port: 6379 }; + } +}; + const conformQueue = new Queue('conform', { - connection: { - host: process.env.REDIS_HOST || 'localhost', - port: process.env.REDIS_PORT || 6379, - }, + connection: parseRedisUrl(process.env.REDIS_URL || 'redis://queue:6379'), }); // GET / - List jobs