Skip to content

Commit b9fdfbd

Browse files
[bugfix] fix code describe (apache#2734)
1 parent 85b4a4e commit b9fdfbd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

collector/collector-rocketmq/src/main/java/org/apache/hertzbeat/collector/collect/rocketmq/RocketmqSingleCollectImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ public void destroy() {
112112
*/
113113
@Override
114114
public void preCheck(Metrics metrics) throws IllegalArgumentException {
115-
Assert.isTrue(metrics != null && metrics.getRocketmq() != null, "Mongodb collect must has rocketmq params");
115+
Assert.isTrue(metrics != null && metrics.getRocketmq() != null, "Rocketmq collect must has rocketmq params");
116116
RocketmqProtocol rocketmq = metrics.getRocketmq();
117117
Assert.hasText(rocketmq.getNamesrvHost(), "Rocketmq Protocol namesrvHost is required.");
118118
Assert.hasText(rocketmq.getNamesrvPort(), "Rocketmq Protocol namesrvPort is required.");

0 commit comments

Comments
 (0)