This is an automated email from the ASF dual-hosted git repository.
zhangyuxuan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hertzbeat.git
The following commit(s) were added to refs/heads/master by this push:
new b9fdfbd50 [bugfix] fix code describe (#2734)
b9fdfbd50 is described below
commit b9fdfbd50e8693077f16ea5e4fed4eba47a226cd
Author: Jast <[email protected]>
AuthorDate: Sat Sep 21 12:51:02 2024 +0800
[bugfix] fix code describe (#2734)
---
.../hertzbeat/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 90ccf20dd..7fa62d66b 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 class RocketmqSingleCollectImpl extends
AbstractCollect implements Dispos
*/
@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.");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
