Implement Client#get_channel_info

Author: michaelklishin

CHANGELOG.md

@@ -4,13 +4,13 @@
 
 ### Enhancements
 
- * `Client#current_user` is a new function providing support for the `GET /api/whoami` endpoint.
  * `Client#auth_attempts_statistics` is a new function providing support for the `GET /api/auth/attempts/{node}` endpoint.
  * `Client#list_topic_permissions` is a new function that provides support for the `GET /api/topic-permissions` endpoint.
  * `Client#list_topic_permissions_in` is a new function that provides support for the `GET /api/vhosts/{vhost}/topic-permissions` endpoint.
  * `Client#get_topic_permissions_of` is a new function that provides support for the `GET /api/topic-permissions/{vhost}/{user}` endpoint.
  * `Client#list_channels_on` is a new function that provides support for the `GET /api/connections/{connection}/channels` endpoint.
-
+ * `Client#get_channel_info` returns information about a specific channel.
+ * `Client#current_user` is a new function providing support for the `GET /api/whoami` endpoint.
 
 ## v0.50.0 (Sep 13, 2025)
 

src/api.rs

@@ -26,7 +26,10 @@ use crate::responses::{
     WarmStandbyReplicationStatus,
 };
 use crate::{
-    commons::{BindingDestinationType, SupportedProtocol, UserLimitTarget, VirtualHostLimitTarget},
+    commons::{
+        BindingDestinationType, SupportedProtocol, UserLimitTarget,
+        VirtualHostLimitTarget,
+    },
     path,
     requests::{
         self, BulkUserDelete, EnforcedLimitParams, ExchangeParams, Permissions, PolicyParams,
@@ -412,6 +415,18 @@ where
             .await
     }
 
+    /// Returns information about a specific channel.
+    ///
+    /// Unlike AMQP 0-9-1, HTTP API identifies channels by a string identifier instead of a numeric ID.
+    ///
+    /// Channel name is usually obtained from `crate::responses::Channel`,
+    /// e.g. via `Client#list_channels`, `Client#list_channels_in`, `Client#list_channels_on`.
+    /// See [Channels Guide](https://www.rabbitmq.com/docs/channels) to learn more.
+    pub async fn get_channel_info<S: AsRef<str>>(&self, channel_name: S) -> Result<responses::Channel> {
+        self.get_api_request(path!("channels", channel_name.as_ref()))
+            .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

@@ -25,7 +25,10 @@ use crate::responses::{
     OAuthConfiguration, VirtualHostDefinitionSet, WarmStandbyReplicationStatus,
 };
 use crate::{
-    commons::{BindingDestinationType, SupportedProtocol, UserLimitTarget, VirtualHostLimitTarget},
+    commons::{
+        BindingDestinationType, SupportedProtocol, UserLimitTarget,
+        VirtualHostLimitTarget,
+    },
     path,
     requests::{
         self, BulkUserDelete, EnforcedLimitParams, ExchangeParams, Permissions, PolicyParams,
@@ -392,6 +395,17 @@ where
         self.get_api_request(path!("connections", connection_name, "channels"))
     }
 
+    /// Returns information about a specific channel.
+    ///
+    /// Unlike AMQP 0-9-1, HTTP API identifies channels by a string identifier instead of a numeric ID.
+    ///
+    /// Channel name is usually obtained from `crate::responses::Channel`,
+    /// e.g. via `Client#list_channels`, `Client#list_channels_in`, `Client#list_channels_on`.
+    /// See [Channels Guide](https://www.rabbitmq.com/docs/channels) to learn more.
+    pub fn get_channel_info<S: AsRef<str>>(&self, channel_name: S) -> Result<responses::Channel> {
+        self.get_api_request(path!("channels", channel_name.as_ref()))
+    }
+
     /// 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

@@ -11,7 +11,7 @@
 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 // See the License for the specific language governing permissions and
 // limitations under the License.
-use amqprs::connection::{Connection, OpenConnectionArguments};
+use amqprs::{channel::ConfirmSelectArguments, connection::{Connection, OpenConnectionArguments}};
 use rabbitmq_http_client::api::Client;
 use std::time::Duration;
 
@@ -86,3 +86,36 @@ async fn test_async_list_channels_on_connection() {
     ch.close().await.unwrap();
     conn.clone().close().await.unwrap();
 }
+
+#[tokio::test]
+async fn test_async_get_channel_info() {
+    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());
+    let _ = ch.confirm_select(ConfirmSelectArguments::default()).await;
+
+    tokio::time::sleep(Duration::from_millis(1000)).await;
+
+    let channels = rc.list_channels().await.unwrap();
+    assert!(!channels.is_empty(), "Expected at least one channel");
+
+    let first_channel = channels.first().unwrap();
+
+    // Note: the HTTP API uses a string channel name, not the numeric ID
+    let result1 = rc.get_channel_info(&first_channel.name).await;
+    assert!(result1.is_ok(), "get_channel_info returned {result1:?}");
+
+    let ch_details = result1.unwrap();
+    assert_eq!(ch_details.vhost, "/");
+    assert_eq!(ch_details.consumer_count, 0, "Expected 0 consumers");
+
+    // just to be explicit
+    ch.close().await.unwrap();
+    conn.clone().close().await.unwrap();
+}