Merge pull request #205 from rabbitmq/zerpet/issue-199

Add a constant for CQ v2 queue argument

examples_test.go

@@ -539,3 +539,19 @@ func ExampleChannel_QueueDeclare_stream() {
 	)
 	log.Printf("Declared queue: %s", q.Name)
 }
+
+func ExampleChannel_QueueDeclare_classicQueueV2() {
+	conn, _ := amqp.Dial("amqp://localhost")
+	ch, _ := conn.Channel()
+	q, _ := ch.QueueDeclare(
+		"my-classic-queue-v2", // queue name
+		true,                  // durable
+		false,                 // auto-delete
+		false,                 // exclusive
+		false,                 // noWait
+		amqp.Table{
+			amqp.QueueVersionArg: 2,
+		},
+	)
+	log.Printf("Declared Classic Queue v2: %s", q.Name)
+}

types.go

@@ -254,6 +254,8 @@ const (
 	QueueTTLArg                  = "x-expires"
 	StreamMaxAgeArg              = "x-max-age"
 	StreamMaxSegmentSizeBytesArg = "x-stream-max-segment-size-bytes"
+	// QueueVersionArg declares the Classic Queue version to use. Expects an integer, either 1 or 2.
+	QueueVersionArg = "x-queue-version"
 )
 
 // Values for queue arguments. Use as values for queue arguments during queue declaration.