connection_properties: add config to recover on channel failure

Experimental, and currently does nothing

Signed-off-by: Marc-Antoine Perennou <[email protected]>

src/connection_properties.rs

@@ -1,4 +1,5 @@
 use crate::{
+    experimental::RecoveryConfig,
     reactor::FullReactor,
     types::{AMQPValue, FieldTable, LongString},
     Error, Result,
@@ -12,6 +13,7 @@ pub struct ConnectionProperties {
     pub client_properties: FieldTable,
     pub executor: Option<Arc<dyn FullExecutor + Send + Sync>>,
     pub reactor: Option<Arc<dyn FullReactor + Send + Sync>>,
+    pub recovery_config: Option<RecoveryConfig>,
 }
 
 impl Default for ConnectionProperties {
@@ -21,6 +23,7 @@ impl Default for ConnectionProperties {
             client_properties: FieldTable::default(),
             executor: None,
             reactor: None,
+            recovery_config: None,
         }
     }
 }
@@ -47,6 +50,12 @@ impl ConnectionProperties {
         self
     }
 
+    #[must_use]
+    pub fn with_experimental_recovery_config(mut self, config: RecoveryConfig) -> Self {
+        self.recovery_config = Some(config);
+        self
+    }
+
     pub(crate) fn take_executor(&mut self) -> Result<Arc<dyn FullExecutor + Send + Sync>> {
         if let Some(executor) = self.executor.take() {
             return Ok(executor);

src/error.rs

@@ -4,7 +4,7 @@ use crate::{
 };
 use amq_protocol::{
     frame::{GenError, ParserError, ProtocolVersion},
-    protocol::{AMQPErrorKind, AMQPSoftError},
+    protocol::AMQPErrorKind,
 };
 use std::{error, fmt, io, sync::Arc};
 

src/lib.rs

@@ -124,6 +124,10 @@ pub mod publisher_confirm;
 pub mod socket_state;
 pub mod topology;
 
+pub mod experimental {
+    pub use crate::recovery_config::RecoveryConfig;
+}
+
 use promise::{Promise, PromiseResolver};
 
 mod acknowledgement;
@@ -156,6 +160,7 @@ mod parsing;
 mod promise;
 mod queue;
 mod reactor;
+mod recovery_config;
 mod registry;
 mod returned_messages;
 mod thread;

src/recovery_config.rs

@@ -0,0 +1,4 @@
+#[derive(Default, Clone)]
+pub struct RecoveryConfig {
+    pub auto_recover_channels: bool,
+}