diff --git a/lib/index.test.ts b/lib/index.test.ts index 36060b8..76a7ce8 100644 --- a/lib/index.test.ts +++ b/lib/index.test.ts @@ -469,7 +469,7 @@ describe("Connection", () => { { autoDelete: true, durable: false, - exclusive: false, + exclusive: true, expires: 432000000, } ); diff --git a/lib/index.ts b/lib/index.ts index 96e6523..eea96d1 100644 --- a/lib/index.ts +++ b/lib/index.ts @@ -222,7 +222,7 @@ class Connection { return this.channel!.assertQueue(queueName, { durable: false, autoDelete: true, - exclusive: false, + exclusive: true, expires: QUEUE_EXPIRATION, }).catch((e) => Promise.reject(new Error(e))); }