Remove unneeded reference

integreat-io · May 17, 2021 · b380ae4 · b380ae4
1 parent e519ac2
commit b380ae4
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/subscribe.test.ts b/src/subscribe.test.ts
@@ -164,3 +164,10 @@ test('should unsubscribe from queue', async (t) => {
 
   await t.context.channel.purgeQueue(queueName)
 })
+
+test('should do nothing when unsubscribe is attempted without queue name', async (t) => {
+  const queueName = 'testQueueUnsubscribe2'
+  const q = await createQueue({ queueName, rabbitmq: rabbitOptions })
+
+  await t.notThrowsAsync(q.unsubscribe(null))
+})