Merge pull request #3634 from harshithasudhakar/patch-7

[ISSUE #3395]Use isEmpty() to check whether the collection is empty or not.[ClientSessionGroupMapping]
apache · Apr 6, 2023 · f3eb86f · f3eb86f
2 parents 4eb819f + baa01d4
commit f3eb86f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rg/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientSessionGroupMapping.java b/...rg/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientSessionGroupMapping.java
@@ -294,7 +294,7 @@ private void cleanSubscriptionInSession(Session session) throws Exception {
     private void handleUnackMsgsInSession(Session session) {
         ConcurrentHashMap<String /** seq */, DownStreamMsgContext> unAckMsg = session.getPusher().getUnAckMsg();
         ClientGroupWrapper clientGroupWrapper = Objects.requireNonNull(session.getClientGroupWrapper().get());
-        if (unAckMsg.size() > 0 && clientGroupWrapper.getGroupConsumerSessions().size() > 0) {
+        if (unAckMsg.size() > 0 && !clientGroupWrapper.getGroupConsumerSessions().isEmpty()) {
             for (Map.Entry<String, DownStreamMsgContext> entry : unAckMsg.entrySet()) {
                 DownStreamMsgContext downStreamMsgContext = entry.getValue();
                 if (SubscriptionMode.BROADCASTING == downStreamMsgContext.getSubscriptionItem().getMode()) {