Update tests and the change log

michaelklishin · michaelklishin · commit 0dcccaa64857 · 2026-01-16T18:50:23.000-08:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,7 +2,13 @@
 
 ## v0.74.0 (in development)
 
-No changes yet.
+### Breaking Changes
+
+ * `ExchangeFederationParams#queue_type` and `OwnedExchangeFederationParams#queue_type` are now
+   optional (`Option<QueueType>` intead of `QueueType`) for RabbitMQ 3.12.x compatibility.
+
+   The [`queue-type`](https://www.rabbitmq.com/docs/federation-reference) parameter was introduced
+   in the 3.13 series.
 
 
 ## v0.73.0 (Dec 30, 2025)
diff --git a/tests/async_queue_federation_tests.rs b/tests/async_queue_federation_tests.rs
@@ -192,7 +192,7 @@ async fn test_async_exchange_federation_upstream_fetch_and_update_workflow() {
     if let Some(ref mut exchange_fed) = modified_params.exchange_federation {
         exchange_fed.exchange = Some("updated-exchange".to_string());
         exchange_fed.max_hops = Some(3);
-        exchange_fed.queue_type = QueueType::Classic;
+        exchange_fed.queue_type = Some(QueueType::Classic);
     }
 
     // Step 5: Convert back to FederationUpstreamParams and update
diff --git a/tests/blocking_queue_federation_tests.rs b/tests/blocking_queue_federation_tests.rs
@@ -170,7 +170,7 @@ fn test_blocking_exchange_federation_upstream_fetch_and_update_workflow() {
     if let Some(ref mut exchange_fed) = modified_params.exchange_federation {
         exchange_fed.exchange = Some("updated-exchange".to_string());
         exchange_fed.max_hops = Some(3);
-        exchange_fed.queue_type = QueueType::Classic;
+        exchange_fed.queue_type = Some(QueueType::Classic);
     }
 
     let updated_upstream_params = FederationUpstreamParams::from(&modified_params);
diff --git a/tests/unit_federation_conversion_tests.rs b/tests/unit_federation_conversion_tests.rs
@@ -254,7 +254,7 @@ fn test_federation_upstream_to_params_conversion_exchange_federation() {
     let exchange_fed = owned_params.exchange_federation.as_ref().unwrap();
     assert_eq!(exchange_fed.exchange.as_ref().unwrap(), "fed.ex.upstream");
     assert_eq!(exchange_fed.max_hops.unwrap(), 2);
-    assert_eq!(exchange_fed.queue_type, QueueType::Quorum);
+    assert_eq!(exchange_fed.queue_type, Some(QueueType::Quorum));
     assert_eq!(exchange_fed.ttl.unwrap(), 3600000);
     assert_eq!(exchange_fed.message_ttl.unwrap(), 7200000);
     assert_eq!(

Original file line number	Diff line number	Diff line change
`@@ -192,7 +192,7 @@ async fn test_async_exchange_federation_upstream_fetch_and_update_workflow() {`
`192`	`192`	`if let Some(ref mut exchange_fed) = modified_params.exchange_federation {`
`193`	`193`	`exchange_fed.exchange = Some("updated-exchange".to_string());`
`194`	`194`	`exchange_fed.max_hops = Some(3);`
`195`		`- exchange_fed.queue_type = QueueType::Classic;`
	`195`	`+ exchange_fed.queue_type = Some(QueueType::Classic);`
`196`	`196`	`}`
`197`	`197`
`198`	`198`	`// Step 5: Convert back to FederationUpstreamParams and update`
Original file line number	Diff line number	Diff line change
`@@ -170,7 +170,7 @@ fn test_blocking_exchange_federation_upstream_fetch_and_update_workflow() {`
`170`	`170`	`if let Some(ref mut exchange_fed) = modified_params.exchange_federation {`
`171`	`171`	`exchange_fed.exchange = Some("updated-exchange".to_string());`
`172`	`172`	`exchange_fed.max_hops = Some(3);`
`173`		`- exchange_fed.queue_type = QueueType::Classic;`
	`173`	`+ exchange_fed.queue_type = Some(QueueType::Classic);`
`174`	`174`	`}`
`175`	`175`
`176`	`176`	`let updated_upstream_params = FederationUpstreamParams::from(&modified_params);`