summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArnaud Cogoluègnes <acogoluegnes@gmail.com>2022-02-02 14:13:31 +0100
committerArnaud Cogoluègnes <acogoluegnes@gmail.com>2022-05-09 10:52:33 +0200
commitb1d0277048a98cbdc6057aa7967f73a70ddf6575 (patch)
tree88557569c89430a4fbdebe3a5a5afc11bf2ab51b
parentad291767233e8429f5d1bf89f7bacfe801e09758 (diff)
downloadrabbitmq-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.java2
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))