Merge pull request #2204 from antiriez/master

[ISSUE #2199]Update EventMeshConsumer.java replace isSize == 0 with isEmpty()
apache · Nov 14, 2022 · 791b197 · 791b197
2 parents 6e9eaf0 + 52fa2d6
commit 791b197
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/EventMeshConsumer.java b/...main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/EventMeshConsumer.java
@@ -133,7 +133,7 @@ public synchronized boolean deregisterClient(ConsumerGroupClient client) {
     }
 
     public synchronized void init() throws Exception {
-        if (consumerGroupTopicConfig.size() == 0) {
+        if (consumerGroupTopicConfig.isEmpty()) {
             // no topics, don't init the consumer
             return;
         }
@@ -163,7 +163,7 @@ public synchronized void init() throws Exception {
     }
 
     public synchronized void start() throws Exception {
-        if (consumerGroupTopicConfig.size() == 0) {
+        if (consumerGroupTopicConfig.isEmpty()) {
             // no topics, don't start the consumer
             return;
         }
@@ -301,4 +301,4 @@ public void onException(OnExceptionContext context) {
             }
         });
     }
-}
+}