From ad2f7cc4efc73fd2736c3d2c10d785164fe42456 Mon Sep 17 00:00:00 2001 From: Sjors <15579298+microwavekonijn@users.noreply.github.com> Date: Sat, 25 Oct 2025 23:23:25 +0200 Subject: [PATCH 1/3] fix: make exclusive queue transient --- .../src/ingress/factories/stream-channel.factory.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts b/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts index 874b5ff..441c6a3 100644 --- a/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts +++ b/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts @@ -25,6 +25,7 @@ export class StreamChannelFactory { setup: async (channel: Channel) => { const { queue } = await channel.assertQueue('', { exclusive: true, + durable: false }); await Promise.all([ From fda52aaa3caf853813822f3313c08d756dd2d3a6 Mon Sep 17 00:00:00 2001 From: Sjors <15579298+microwavekonijn@users.noreply.github.com> Date: Sat, 25 Oct 2025 23:25:10 +0200 Subject: [PATCH 2/3] chore: fix lint --- .../src/ingress/factories/stream-channel.factory.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts b/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts index 441c6a3..29191c4 100644 --- a/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts +++ b/apps/stream-manifold/src/ingress/factories/stream-channel.factory.ts @@ -25,7 +25,7 @@ export class StreamChannelFactory { setup: async (channel: Channel) => { const { queue } = await channel.assertQueue('', { exclusive: true, - durable: false + durable: false, }); await Promise.all([ From 81970e0d207dcfcf8e04b682d2d2faf25ea52ea5 Mon Sep 17 00:00:00 2001 From: Sjors <15579298+microwavekonijn@users.noreply.github.com> Date: Sat, 25 Oct 2025 23:25:47 +0200 Subject: [PATCH 3/3] chore: add changeset Make the exclusive queue transient to improve functionality. --- .changeset/little-fishes-sing.md | 5 +++++ 1 file changed, 5 insertions(+) create mode 100644 .changeset/little-fishes-sing.md diff --git a/.changeset/little-fishes-sing.md b/.changeset/little-fishes-sing.md new file mode 100644 index 0000000..222459e --- /dev/null +++ b/.changeset/little-fishes-sing.md @@ -0,0 +1,5 @@ +--- +"stream-manifold": patch +--- + +fix: make exclusive queue transient