diff --git a/src/server/lifecycle/queue-lifecycle.service.ts b/src/server/lifecycle/queue-lifecycle.service.ts
index 8bd49d1..fe2c44d 100644
--- a/src/server/lifecycle/queue-lifecycle.service.ts
+++ b/src/server/lifecycle/queue-lifecycle.service.ts
@@ -40,11 +40,11 @@ export class QueueLifecycle implements OnModuleDestroy {
   private readonly logger = new Logger(QueueLifecycle.name)
 
   constructor(
-    private readonly workers: WorkerRegistry,
-    private readonly events: QueueEventsRegistry,
-    private readonly queues: QueueService,
-    private readonly flow: FlowService,
-    private readonly connection: ConnectionResolver,
+    @Inject(WorkerRegistry) private readonly workers: WorkerRegistry,
+    @Inject(QueueEventsRegistry) private readonly events: QueueEventsRegistry,
+    @Inject(QueueService) private readonly queues: QueueService,
+    @Inject(FlowService) private readonly flow: FlowService,
+    @Inject(ConnectionResolver) private readonly connection: ConnectionResolver,
     @Inject(BYMAX_QUEUE_RESOLVED_OPTIONS) private readonly resolved: ResolvedQueueOptions,
   ) {}
 
diff --git a/src/server/services/processor-discovery.service.ts b/src/server/services/processor-discovery.service.ts
index 86f1ad0..c6c0fec 100644
--- a/src/server/services/processor-discovery.service.ts
+++ b/src/server/services/processor-discovery.service.ts
@@ -8,7 +8,7 @@
  * @layer server/services
  */
 
-import { Injectable, Logger, type OnModuleInit } from '@nestjs/common'
+import { Inject, Injectable, Logger, type OnModuleInit } from '@nestjs/common'
 import { DiscoveryService } from '@nestjs/core'
 import type { Job } from 'bullmq'
 import { WorkerRegistry } from './worker-registry.service'
@@ -61,9 +61,9 @@ export class ProcessorDiscoveryService implements OnModuleInit {
   private readonly registeredQueues = new Set<string>()
 
   constructor(
-    private readonly discovery: DiscoveryService,
-    private readonly workers: WorkerRegistry,
-    private readonly events: QueueEventsRegistry,
+    @Inject(DiscoveryService) private readonly discovery: DiscoveryService,
+    @Inject(WorkerRegistry) private readonly workers: WorkerRegistry,
+    @Inject(QueueEventsRegistry) private readonly events: QueueEventsRegistry,
   ) {}
 
   /**
diff --git a/src/server/services/queue-events-registry.service.ts b/src/server/services/queue-events-registry.service.ts
index f35c494..e0cd0a6 100644
--- a/src/server/services/queue-events-registry.service.ts
+++ b/src/server/services/queue-events-registry.service.ts
@@ -7,7 +7,7 @@
  * @layer server/services
  */
 
-import { Injectable } from '@nestjs/common'
+import { Inject, Injectable } from '@nestjs/common'
 import { QueueEvents } from 'bullmq'
 import type { Redis } from 'ioredis'
 import { ConnectionResolver } from './connection-resolver.service'
@@ -34,7 +34,7 @@ export class QueueEventsRegistry {
   private readonly events = new Map<string, QueueEvents>()
   private readonly connections = new Map<string, Redis>()
 
-  constructor(private readonly connection: ConnectionResolver) {}
+  constructor(@Inject(ConnectionResolver) private readonly connection: ConnectionResolver) {}
 
   /**
    * Returns the cached `QueueEvents` for `queueName`, creating one on first
diff --git a/src/server/services/queue.service.ts b/src/server/services/queue.service.ts
index 8aebc68..bb8cfa1 100644
--- a/src/server/services/queue.service.ts
+++ b/src/server/services/queue.service.ts
@@ -36,7 +36,7 @@ export class QueueService implements OnModuleDestroy {
   private readonly queues = new Map<string, Queue>()
 
   constructor(
-    private readonly connection: ConnectionResolver,
+    @Inject(ConnectionResolver) private readonly connection: ConnectionResolver,
     @Inject(BYMAX_QUEUE_RESOLVED_OPTIONS) private readonly options: ResolvedQueueOptions,
   ) {}
 
diff --git a/src/server/services/worker-registry.service.ts b/src/server/services/worker-registry.service.ts
index 5aac130..ff9a77b 100644
--- a/src/server/services/worker-registry.service.ts
+++ b/src/server/services/worker-registry.service.ts
@@ -99,7 +99,7 @@ export class WorkerRegistry {
   private readonly entries = new Map<string, WorkerEntry>()
 
   constructor(
-    private readonly connection: ConnectionResolver,
+    @Inject(ConnectionResolver) private readonly connection: ConnectionResolver,
     @Inject(BYMAX_QUEUE_RESOLVED_OPTIONS) private readonly options: ResolvedQueueOptions,
   ) {}