2.18.0

Author: michaelklishin

CHANGELOG.md

@@ -1,8 +1,14 @@
 # rabbitmqadmin-ng Change Log
 
-## v2.18.0 (in development)
+## v2.18.0 (Dec 11, 2025)
 
-No changes yet.
+### Enhancements
+
+ * `--page` and `--page-size` options for paginated listing of queues, streams, and connections
+
+### Upgrades
+
+ * RabbitMQ HTTP API client was upgraded to [`0.70.0`](https://github.com/michaelklishin/rabbitmq-http-api-rs/releases/tag/v0.70.0)
 
 
 ## v2.17.0 (Nov 29, 2025)

Cargo.lock

@@ -17,7 +17,7 @@ reqwest = { version = "0.12", features = [
     "__rustls",
     "rustls-tls-native-roots",
 ] }
-rabbitmq_http_client = { version = "0.68.0", features = [
+rabbitmq_http_client = { version = "0.70", features = [
     "blocking",
     "tabled",
 ] }

Cargo.toml

@@ -629,6 +629,21 @@ pub fn parser(pre_flight_settings: PreFlightSettings) -> Command {
         .subcommands(command_groups)
 }
 
+fn pagination_args() -> [Arg; 2] {
+    [
+        Arg::new("page")
+            .long("page")
+            .help("page number (1-indexed)")
+            .required(false)
+            .value_parser(value_parser!(u64).range(1..)),
+        Arg::new("page_size")
+            .long("page-size")
+            .help("number of results per page (default: 100, max: 500)")
+            .required(false)
+            .value_parser(value_parser!(u64).range(1..=500)),
+    ]
+}
+
 fn list_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Command> {
     let nodes_cmd = Command::new("nodes").long_about("Lists cluster members");
     let vhosts_cmd = Command::new("vhosts")
@@ -648,7 +663,8 @@ fn list_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Command> {
         .after_help(color_print::cformat!(
             "<bold>Doc guide</bold>: {}",
             CONNECTION_GUIDE_URL
-        ));
+        ))
+        .args(pagination_args());
     let channels_cmd = Command::new("channels")
         .long_about("Lists AMQP 0-9-1 channels")
         .after_help(color_print::cformat!(
@@ -660,7 +676,8 @@ fn list_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Command> {
         .after_help(color_print::cformat!(
             "<bold>Doc guide</bold>: {}",
             QUEUE_GUIDE_URL
-        ));
+        ))
+        .args(pagination_args());
     let exchanges_cmd = Command::new("exchanges").long_about("Lists exchanges");
     let bindings_cmd = Command::new("bindings").long_about("Lists bindings");
     let consumers_cmd = Command::new("consumers")
@@ -1578,7 +1595,8 @@ fn queues_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Command> {
         .after_help(color_print::cformat!(
             "<bold>Doc guide</bold>: {}",
             QUEUE_GUIDE_URL
-        ));
+        ))
+        .args(pagination_args());
     let purge_cmd = Command::new("purge")
         .long_about("Purges (permanently removes unacknowledged messages from) a queue")
         .arg(
@@ -1647,11 +1665,12 @@ fn streams_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Command> {
         )
         .arg(idempotently_arg.clone());
     let list_cmd = Command::new("list")
-        .long_about("Lists streams and queues and")
+        .long_about("Lists streams and queues")
         .after_help(color_print::cformat!(
             "<bold>Doc guide</bold>: {}",
             STREAM_GUIDE_URL
-        ));
+        ))
+        .args(pagination_args());
     [declare_cmd, delete_cmd, list_cmd]
         .into_iter()
         .map(|cmd| cmd.infer_long_args(pre_flight_settings.infer_long_options))
@@ -2381,7 +2400,8 @@ fn connections_subcommands(pre_flight_settings: PreFlightSettings) -> Vec<Comman
         .after_help(color_print::cformat!(
             "<bold>Doc guide</bold>: {}",
             CONNECTION_GUIDE_URL
-        ));
+        ))
+        .args(pagination_args());
     let list_user_connections_cmd = Command::new("list_of_user")
         .arg(
             Arg::new("username")

src/cli.rs

@@ -21,6 +21,7 @@ use clap::ArgMatches;
 use rabbitmq_http_client::blocking_api::Client;
 use rabbitmq_http_client::blocking_api::Result as ClientResult;
 use rabbitmq_http_client::commons;
+use rabbitmq_http_client::commons::PaginationParams;
 use rabbitmq_http_client::commons::QueueType;
 use rabbitmq_http_client::commons::{
     BindingDestinationType, ChannelUseMode, TlsPeerVerificationMode,
@@ -102,8 +103,27 @@ pub fn list_users(client: APIClient) -> ClientResult<Vec<responses::User>> {
     client.list_users()
 }
 
-pub fn list_connections(client: APIClient) -> ClientResult<Vec<responses::Connection>> {
-    client.list_connections()
+pub fn list_connections(
+    client: APIClient,
+    command_args: &ArgMatches,
+) -> ClientResult<Vec<responses::Connection>> {
+    let pagination = extract_pagination_params(command_args);
+    match pagination {
+        Some(params) => client.list_connections_paged(&params),
+        None => client.list_connections(),
+    }
+}
+
+fn extract_pagination_params(command_args: &ArgMatches) -> Option<PaginationParams> {
+    let page = command_args.get_one::<u64>("page").map(|&v| v as usize);
+    let page_size = command_args
+        .get_one::<u64>("page_size")
+        .map(|&v| v as usize);
+    if page.is_some() || page_size.is_some() {
+        Some(PaginationParams { page, page_size })
+    } else {
+        None
+    }
 }
 
 pub fn list_user_connections(
@@ -233,8 +253,16 @@ pub fn list_matching_operator_policies_in(
         .collect())
 }
 
-pub fn list_queues(client: APIClient, vhost: &str) -> ClientResult<Vec<responses::QueueInfo>> {
-    client.list_queues_in(vhost)
+pub fn list_queues(
+    client: APIClient,
+    vhost: &str,
+    command_args: &ArgMatches,
+) -> ClientResult<Vec<responses::QueueInfo>> {
+    let pagination = extract_pagination_params(command_args);
+    match pagination {
+        Some(params) => client.list_queues_in_paged(vhost, &params),
+        None => client.list_queues_in(vhost),
+    }
 }
 
 pub fn list_exchanges(

src/commands.rs

@@ -466,7 +466,7 @@ fn dispatch_common_subcommand(
             res_handler.no_output_on_success(result);
         }
         ("connections", "list") => {
-            let result = commands::list_connections(client);
+            let result = commands::list_connections(client, second_level_args);
             res_handler.tabular_result(result)
         }
         ("connections", "list_of_user") => {
@@ -748,7 +748,7 @@ fn dispatch_common_subcommand(
             res_handler.tabular_result(result)
         }
         ("list", "connections") => {
-            let result = commands::list_connections(client);
+            let result = commands::list_connections(client, second_level_args);
             res_handler.tabular_result(result)
         }
         ("list", "consumers") => {
@@ -792,7 +792,7 @@ fn dispatch_common_subcommand(
             res_handler.tabular_result(result)
         }
         ("list", "queues") => {
-            let result = commands::list_queues(client, &vhost);
+            let result = commands::list_queues(client, &vhost, second_level_args);
             res_handler.tabular_result(result)
         }
         ("list", "user_connections") => {
@@ -1038,7 +1038,7 @@ fn dispatch_common_subcommand(
             res_handler.delete_operation_result(result);
         }
         ("queues", "list") => {
-            let result = commands::list_queues(client, &vhost);
+            let result = commands::list_queues(client, &vhost, second_level_args);
             res_handler.tabular_result(result)
         }
         ("queues", "purge") => {
@@ -1169,7 +1169,7 @@ fn dispatch_common_subcommand(
             res_handler.delete_operation_result(result);
         }
         ("streams", "list") => {
-            let result = commands::list_queues(client, &vhost);
+            let result = commands::list_queues(client, &vhost, second_level_args);
             res_handler.tabular_result(result)
         }
         ("users", "connections") => {

src/main.rs

@@ -44,7 +44,15 @@ fn list_exchanges() -> Result<(), Box<dyn Error>> {
             .and(output_includes(x2).not()),
     );
 
-    run_succeeds(["-V", vh1, "delete", "exchange", "--name", x1]);
+    run_succeeds([
+        "-V",
+        vh1,
+        "delete",
+        "exchange",
+        "--name",
+        x1,
+        "--idempotently",
+    ]);
 
     run_succeeds(["-V", vh1, "list", "exchanges"]).stdout(
         output_includes("amq.direct")
@@ -91,7 +99,15 @@ fn exchanges_list() -> Result<(), Box<dyn Error>> {
             .and(output_includes(x2).not()),
     );
 
-    run_succeeds(["-V", vh1, "exchanges", "delete", "--name", x1]);
+    run_succeeds([
+        "-V",
+        vh1,
+        "exchanges",
+        "delete",
+        "--name",
+        x1,
+        "--idempotently",
+    ]);
 
     run_succeeds(["-V", vh1, "exchanges", "list"]).stdout(
         output_includes("amq.direct")