[Improve] add @OverRide

apache · Jul 5, 2024 · 122ef43 · 122ef43
1 parent 65d69eb
commit 122ef43
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
diff --git a/collector/src/main/java/org/apache/hertzbeat/collector/collect/ftp/FtpCollectImpl.java b/collector/src/main/java/org/apache/hertzbeat/collector/collect/ftp/FtpCollectImpl.java
@@ -44,6 +44,7 @@ public class FtpCollectImpl extends AbstractCollect {
     /**
      * preCheck params
      */
+    @Override
     public void preCheck(Metrics metrics) throws IllegalArgumentException{
         if (metrics == null || metrics.getFtp() == null) {
             throw new IllegalArgumentException("Ftp collect must has ftp params.");

diff --git a/...rc/main/java/org/apache/hertzbeat/collector/collect/mongodb/MongodbSingleCollectImpl.java b/...rc/main/java/org/apache/hertzbeat/collector/collect/mongodb/MongodbSingleCollectImpl.java
@@ -88,6 +88,7 @@ public MongodbSingleCollectImpl() {
     /**
      * Check that the mongodb connection information in metrics is complete
      */
+    @Override
     public void preCheck(Metrics metrics) throws IllegalArgumentException{
         Assert.isTrue(metrics != null && metrics.getMongodb() != null, "Mongodb collect must has mongodb params");
         MongodbProtocol mongodbProtocol = metrics.getMongodb();

diff --git a/...or/src/main/java/org/apache/hertzbeat/collector/collect/mq/RocketmqSingleCollectImpl.java b/...or/src/main/java/org/apache/hertzbeat/collector/collect/mq/RocketmqSingleCollectImpl.java
@@ -110,6 +110,7 @@ public void destroy() {
      * preCheck params
      * @param metrics metrics config
      */
+    @Override
     public void preCheck(Metrics metrics) throws IllegalArgumentException {
         Assert.isTrue(metrics != null && metrics.getRocketmq() != null, "Mongodb collect must has rocketmq params");
         RocketmqProtocol rocketmq = metrics.getRocketmq();

diff --git a/...or/src/main/java/org/apache/hertzbeat/collector/collect/redis/RedisCommonCollectImpl.java b/...or/src/main/java/org/apache/hertzbeat/collector/collect/redis/RedisCommonCollectImpl.java
@@ -73,6 +73,7 @@ public RedisCommonCollectImpl() {
         connectionCommonCache = new ConnectionCommonCache<>();
     }
 
+    @Override
     public void preCheck(Metrics metrics) throws IllegalArgumentException{
         Assert.noNullElements(new Object[] {metrics, metrics.getRedis()}, "Redis collect must has redis params");
         RedisProtocol redisProtocol = metrics.getRedis();