From b9fdfbd50e8693077f16ea5e4fed4eba47a226cd Mon Sep 17 00:00:00 2001 From: Jast Date: Sat, 21 Sep 2024 12:51:02 +0800 Subject: [PATCH] [bugfix] fix code describe (#2734) --- .../collector/collect/rocketmq/RocketmqSingleCollectImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/collector/collector-rocketmq/src/main/java/org/apache/hertzbeat/collector/collect/rocketmq/RocketmqSingleCollectImpl.java b/collector/collector-rocketmq/src/main/java/org/apache/hertzbeat/collector/collect/rocketmq/RocketmqSingleCollectImpl.java index 90ccf20dd07..7fa62d66b75 100644 --- a/collector/collector-rocketmq/src/main/java/org/apache/hertzbeat/collector/collect/rocketmq/RocketmqSingleCollectImpl.java +++ b/collector/collector-rocketmq/src/main/java/org/apache/hertzbeat/collector/collect/rocketmq/RocketmqSingleCollectImpl.java @@ -112,7 +112,7 @@ public void destroy() { */ @Override public void preCheck(Metrics metrics) throws IllegalArgumentException { - Assert.isTrue(metrics != null && metrics.getRocketmq() != null, "Mongodb collect must has rocketmq params"); + Assert.isTrue(metrics != null && metrics.getRocketmq() != null, "Rocketmq collect must has rocketmq params"); RocketmqProtocol rocketmq = metrics.getRocketmq(); Assert.hasText(rocketmq.getNamesrvHost(), "Rocketmq Protocol namesrvHost is required."); Assert.hasText(rocketmq.getNamesrvPort(), "Rocketmq Protocol namesrvPort is required.");