diff --git a/apps/data-service/src/index.ts b/apps/data-service/src/index.ts
index 1a749d7..4f993a0 100644
--- a/apps/data-service/src/index.ts
+++ b/apps/data-service/src/index.ts
@@ -112,8 +112,7 @@ async function initializeServices() {
       enableScheduledJobs: true,
     };
     
-    queueManager = QueueManager.getInstance(queueManagerConfig);
-    await queueManager.initialize();
+    queueManager = QueueManager.getOrInitialize(queueManagerConfig);
     logger.info('Queue system initialized');
 
     // Initialize providers (register handlers and scheduled jobs)