channel: account for confirm_select when restoring topology

amqp-rs · Aug 29, 2024 · bb0ba23 · bb0ba23
1 parent 1d7d58b
commit bb0ba23
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/channel.rs b/src/channel.rs
@@ -148,6 +148,12 @@ impl Channel {
         ch: &ChannelDefinitionInternal,
         c: &mut RestoredChannel,
     ) -> Result<()> {
+        if let Some(channel) = ch.channel.as_ref() {
+            if channel.status.confirm() {
+                c.confirm_select(ConfirmSelectOptions::default()).await?;
+            }
+        }
+
         // First, redeclare all queues
         for queue in &ch.queues {
             if queue.is_declared() {