Add Client#list_stream_connections

src/api.rs

@@ -254,7 +254,7 @@ where
         Ok(response)
     }
 
-    /// Lists all client connections across the cluster.
+    /// Lists all AMQP 1.0 and 0-9-1 client connections across the cluster.
     pub async fn list_connections(&self) -> Result<Vec<responses::Connection>> {
         let response = self.http_get("connections", None, None).await?;
         let response = response.json().await?;
@@ -314,6 +314,13 @@ where
         Ok(response)
     }
 
+    /// Lists all RabbitMQ Stream Protocol client connections across the cluster.
+    pub async fn list_stream_connections(&self) -> Result<Vec<responses::Connection>> {
+        let response = self.http_get("stream/connections", None, None).await?;
+        let response = response.json().await?;
+        Ok(response)
+    }
+
     /// Lists all channels across the cluster.
     pub async fn list_channels(&self) -> Result<Vec<responses::Channel>> {
         let response = self.http_get("channels", None, None).await?;

src/blocking_api.rs

@@ -252,7 +252,7 @@ where
         Ok(response)
     }
 
-    /// Lists all client connections across the cluster.
+    /// Lists all AMQP 1.0 and 0-9-1 client connections across the cluster.
     pub fn list_connections(&self) -> Result<Vec<responses::Connection>> {
         let response = self.http_get("connections", None, None)?;
         let response = response.json()?;
@@ -296,6 +296,13 @@ where
         Ok(response)
     }
 
+    /// Lists all RabbitMQ Stream Protocol client connections across the cluster.
+    pub fn list_stream_connections(&self) -> Result<Vec<responses::Connection>> {
+        let response = self.http_get("stream/connections", None, None)?;
+        let response = response.json()?;
+        Ok(response)
+    }
+
     /// Lists all channels across the cluster.
     pub fn list_channels(&self) -> Result<Vec<responses::Channel>> {
         let response = self.http_get("channels", None, None)?;

tests/connection_tests.rs

@@ -51,3 +51,16 @@ fn test_list_virtual_host_connections() {
         result1
     );
 }
+
+#[test]
+fn test_list_stream_connections() {
+    let endpoint = endpoint();
+    let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+
+    let result1 = rc.list_stream_connections();
+    assert!(
+        result1.is_ok(),
+        "list_stream_connections returned {:?}",
+        result1
+    );
+}