add helper to set connection_name

Fixes amqp-rs#319 Signed-off-by: Marc-Antoine Perennou <[email protected]>
Appva · Jan 18, 2021 · 12ad229 · 12ad229
1 parent 5785da0
commit 12ad229
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/examples/pubsub.rs b/examples/pubsub.rs
@@ -17,7 +17,7 @@ fn main() -> Result<()> {
     async_global_executor::block_on(async {
         let conn = Connection::connect(
             &addr,
-            ConnectionProperties::default().with_default_executor(8),
+            ConnectionProperties::default().with_default_executor(8).with_connection_name("pubsub-example".into()),
         )
         .await?;
 

diff --git a/src/connection_properties.rs b/src/connection_properties.rs
@@ -1,7 +1,7 @@
 use crate::{
     executor::{DefaultExecutor, Executor},
     reactor::ReactorBuilder,
-    types::FieldTable,
+    types::{AMQPValue, FieldTable, LongString},
 };
 use std::sync::Arc;
 
@@ -25,6 +25,11 @@ impl Default for ConnectionProperties {
 }
 
 impl ConnectionProperties {
+    pub fn with_connection_name(mut self, connection_name: LongString) -> Self {
+        self.client_properties.insert("connection_name".into(), AMQPValue::LongString(connection_name));
+        self
+    }
+
     pub fn with_executor<E: Executor + 'static>(mut self, executor: E) -> Self {
         self.executor = Some(Arc::new(executor));
         self