From 9e8a9dafb80c35e11eb5f6487aa0a4a74010598d Mon Sep 17 00:00:00 2001
From: Sky Walters <79102296+dynamicbark@users.noreply.github.com>
Date: Fri, 27 Feb 2026 03:28:30 -0500
Subject: [PATCH] fix(api): Fix nats filter subject

---
 packages/api/src/worker/JetStreamWorkerQueue.tsx | 1 +
 1 file changed, 1 insertion(+)

diff --git a/packages/api/src/worker/JetStreamWorkerQueue.tsx b/packages/api/src/worker/JetStreamWorkerQueue.tsx
index 3a7abdcf..898541e6 100644
--- a/packages/api/src/worker/JetStreamWorkerQueue.tsx
+++ b/packages/api/src/worker/JetStreamWorkerQueue.tsx
@@ -70,6 +70,7 @@ export class JetStreamWorkerQueue {
 		} catch {
 			await jsm.consumers.add(STREAM_NAME, {
 				durable_name: CONSUMER_NAME,
+				filter_subject: `${SUBJECT_PREFIX}>`,
 				ack_policy: AckPolicy.Explicit,
 				max_deliver: MAX_DELIVER,
 				ack_wait: nanos(ACK_WAIT_MS),