From da0418e81b2004afd78b131e7f4d914fa87388da Mon Sep 17 00:00:00 2001
From: Luke Bakken <luke@bakken.io>
Date: Sun, 7 Jul 2024 16:29:19 -0700
Subject: [PATCH] Add test that demonstrates that RabbitMQ behaves according to
 spec

Related to #273
---
 .ci/versions.json   |  4 ++--
 integration_test.go | 43 +++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 45 insertions(+), 2 deletions(-)

diff --git a/.ci/versions.json b/.ci/versions.json
index 231e0b5..5753333 100644
--- a/.ci/versions.json
+++ b/.ci/versions.json
@@ -1,4 +1,4 @@
 {
-  "erlang": "26.2.2",
-  "rabbitmq": "3.13.0"
+  "erlang": "26.2.5.1",
+  "rabbitmq": "3.13.4"
 }
diff --git a/integration_test.go b/integration_test.go
index 7d0d93c..f336f25 100644
--- a/integration_test.go
+++ b/integration_test.go
@@ -286,6 +286,49 @@ func TestIntegrationQueueDeclarePassiveOnMissingExchangeShouldError(t *testing.T
 	}
 }
 
+// https://github.com/rabbitmq/amqp091-go/issues/273
+// Note: RabbitMQ behaves according to spec.
+// Passive declarations ignore everything but the queue name
+// #themoreuknow
+func TestIntegrationQueueDeclarePassiveOnQueueTypeMismatchShouldError(t *testing.T) {
+	c := integrationConnection(t, t.Name())
+	if c != nil {
+		defer c.Close()
+
+		ch, err := c.Channel()
+		if err != nil {
+			t.Fatalf("create channel1: %s", err)
+		}
+		defer ch.Close()
+
+		queueName := t.Name()
+
+		if _, err := ch.QueueDeclare(
+			queueName, // name
+			false, // durable
+			true,  // auto-delete
+			false, // exclusive
+			false, // noWait
+			nil,   // arguments
+		); err != nil {
+			t.Fatalf("queue declare: %s", err)
+		}
+
+		args := Table{QueueTypeArg: QueueTypeQuorum}
+
+		if _, err := ch.QueueDeclarePassive(
+			queueName, // name
+			false,                                    // duration (note: not durable)
+			true,                                     // auto-delete
+			false,                                    // exclusive
+			false,                                    // noWait
+			args,                                      // arguments
+		); err != nil {
+			t.Fatal("QueueDeclarePassive with mismatched queue type should NOT error")
+		}
+	}
+}
+
 // https://github.com/streadway/amqp/issues/94
 func TestIntegrationPassiveQueue(t *testing.T) {
 	c := integrationConnection(t, "queue")