diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-02-02 14:13:31 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-05-09 10:52:33 +0200 |
| commit | b1d0277048a98cbdc6057aa7967f73a70ddf6575 (patch) | |
| tree | 88557569c89430a4fbdebe3a5a5afc11bf2ab51b | |
| parent | ad291767233e8429f5d1bf89f7bacfe801e09758 (diff) | |
| download | rabbitmq-server-git-b1d0277048a98cbdc6057aa7967f73a70ddf6575.tar.gz | |
Check active and activity_status metrics field
References #3753
| -rw-r--r-- | deps/rabbitmq_stream_management/test/http_SUITE_data/src/test/java/com/rabbitmq/stream/HttpTest.java | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/deps/rabbitmq_stream_management/test/http_SUITE_data/src/test/java/com/rabbitmq/stream/HttpTest.java b/deps/rabbitmq_stream_management/test/http_SUITE_data/src/test/java/com/rabbitmq/stream/HttpTest.java index 495c831b6a..f4448e6e23 100644 --- a/deps/rabbitmq_stream_management/test/http_SUITE_data/src/test/java/com/rabbitmq/stream/HttpTest.java +++ b/deps/rabbitmq_stream_management/test/http_SUITE_data/src/test/java/com/rabbitmq/stream/HttpTest.java @@ -572,6 +572,8 @@ public class HttpTest { assertThat(((Number) consumer.get("consumed")).intValue()).isEqualTo(0); assertThat(((Number) consumer.get("offset")).intValue()).isEqualTo(0); assertThat(((Number) consumer.get("subscription_id")).intValue()).isEqualTo(0); + assertThat(consumer.get("active")).isEqualTo(true); + assertThat(consumer.get("activity_status")).isEqualTo("up"); assertThat(consumer.get("properties")).isNotNull().isEqualTo(subscriptionProperties); assertThat(connectionDetails(consumer)) |
