diff --git a/filter/pom.xml b/filter/pom.xml index b2036202e4322438b82e1c69721e6a4033776649..7f33e996285f52962bbbc9c2bed5645573b6b94b 100644 --- a/filter/pom.xml +++ b/filter/pom.xml @@ -37,5 +37,9 @@ ${project.groupId} rocketmq-srvutil + + com.google.guava + guava + \ No newline at end of file diff --git a/srvutil/pom.xml b/srvutil/pom.xml index bf3f11c2fea0ef7320a1bd38e9b66e7db93817b8..d616edd95ee94b4310926e4c24032576b36cc40f 100644 --- a/srvutil/pom.xml +++ b/srvutil/pom.xml @@ -41,9 +41,5 @@ commons-cli commons-cli - - com.google.guava - guava - diff --git a/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java b/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java index adf61adbd8303ce6bbf26e814b1177063f0ee236..111cedea792f46253ada9d4864dbd735872bc550 100644 --- a/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java +++ b/srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java @@ -17,7 +17,6 @@ package org.apache.rocketmq.srvutil; -import com.google.common.base.Strings; import java.io.File; import java.io.IOException; import java.nio.file.Files; @@ -27,6 +26,7 @@ import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.ArrayList; import java.util.List; +import org.apache.commons.lang3.StringUtils; import org.apache.rocketmq.common.ServiceThread; import org.apache.rocketmq.common.UtilAll; import org.apache.rocketmq.common.constant.LoggerName; @@ -49,7 +49,7 @@ public class FileWatchService extends ServiceThread { this.fileCurrentHash = new ArrayList<>(); for (int i = 0; i < watchFiles.length; i++) { - if (!Strings.isNullOrEmpty(watchFiles[i]) && new File(watchFiles[i]).exists()) { + if (StringUtils.isNotEmpty(watchFiles[i]) && new File(watchFiles[i]).exists()) { this.watchFiles.add(watchFiles[i]); this.fileCurrentHash.add(hash(watchFiles[i])); }