Support one more endpoint for listing channels

Author: michaelklishin

src/api.rs

@@ -405,6 +405,13 @@ where
             .await
     }
 
+    /// Lists all channels on a given AMQP 0-9-1 connection.
+    /// See [Channels Guide](https://www.rabbitmq.com/docs/channels) to learn more.
+    pub async fn list_channels_on(&self, connection_name: &str) -> Result<Vec<responses::Channel>> {
+        self.get_api_request(path!("connections", connection_name, "channels"))
+            .await
+    }
+
     /// Lists all stream publishers across the cluster.
     pub async fn list_stream_publishers(&self) -> Result<Vec<responses::StreamPublisher>> {
         let response = self

src/blocking_api.rs

@@ -386,6 +386,12 @@ where
         self.get_api_request(path!("vhosts", virtual_host, "channels"))
     }
 
+    /// Lists all channels on a given AMQP 0-9-1 connection.
+    /// See [Channels Guide](https://www.rabbitmq.com/docs/channels) to learn more.
+    pub fn list_channels_on(&self, connection_name: &str) -> Result<Vec<responses::Channel>> {
+        self.get_api_request(path!("connections", connection_name, "channels"))
+    }
+
     /// Lists all stream publishers across the cluster.
     pub fn list_stream_publishers(&self) -> Result<Vec<responses::StreamPublisher>> {
         self.get_api_request(path!("stream", "publishers"))

tests/async_channel_tests.rs

@@ -13,12 +13,13 @@
 // limitations under the License.
 use amqprs::connection::{Connection, OpenConnectionArguments};
 use rabbitmq_http_client::api::Client;
+use std::time::Duration;
 
 mod test_helpers;
 use crate::test_helpers::{PASSWORD, USERNAME, endpoint, hostname};
 
 #[tokio::test]
-async fn test_list_channels() {
+async fn test_async_list_channels() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
@@ -38,7 +39,7 @@ async fn test_list_channels() {
 }
 
 #[tokio::test]
-async fn test_list_virtual_host_channels() {
+async fn test_async_list_virtual_host_channels() {
     let endpoint = endpoint();
     let rc = Client::new(&endpoint, USERNAME, PASSWORD);
 
@@ -57,3 +58,31 @@ async fn test_list_virtual_host_channels() {
     ch.close().await.unwrap();
     conn.clone().close().await.unwrap();
 }
+
+#[tokio::test]
+async fn test_async_list_channels_on_connection() {
+    let endpoint = endpoint();
+    let rc = Client::new(&endpoint, USERNAME, PASSWORD);
+
+    let args = OpenConnectionArguments::new(&hostname(), 5672, USERNAME, PASSWORD);
+    let conn = Connection::open(&args).await.unwrap();
+    assert!(conn.is_open());
+
+    let ch = conn.open_channel(None).await.unwrap();
+    assert!(ch.is_open());
+
+    tokio::time::sleep(Duration::from_millis(1000)).await;
+
+    let connections = rc.list_connections().await.unwrap();
+    let first = connections.first().unwrap();
+
+    let result1 = rc.list_channels_on(&first.name).await;
+    assert!(result1.is_ok(), "list_channels_on returned {result1:?}");
+
+    let channels = result1.unwrap();
+    assert_eq!(1, channels.len());
+
+    // just to be explicit
+    ch.close().await.unwrap();
+    conn.clone().close().await.unwrap();
+}