[rocketmq] branch develop updated: [ISSUE #6043] Optimize the DefaultLitePullConsumerImpl isSetEqual method code (#6044)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 2e8ef0464 [ISSUE #6043] Optimize the DefaultLitePullConsumerImpl 
isSetEqual method code (#6044)
2e8ef0464 is described below

commit 2e8ef046465c4133cf0d6ad6f242f630021439b2
Author: hardyfish <85128645+hardyf...@users.noreply.github.com>
AuthorDate: Mon Feb 13 13:38:30 2023 +0800

    [ISSUE #6043] Optimize the DefaultLitePullConsumerImpl isSetEqual method 
code (#6044)
    
    * optimize the DefaultLitePullConsumerImpl isSetEqual method code
    
    * optimize the DefaultLitePullConsumerImpl isSetEqual method code
---
 .../rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
index 793778e03..c6631cb5e 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
@@ -1215,12 +1215,11 @@ public class DefaultLitePullConsumerImpl implements 
MQConsumerInner {
             return true;
         }
 
-        if (set1 == null || set2 == null || set1.size() != set2.size()
-            || set1.size() == 0 || set2.size() == 0) {
+        if (set1 == null || set2 == null || set1.size() != set2.size() || 
set1.size() == 0) {
             return false;
         }
 
-        Iterator iter = set2.iterator();
+        Iterator<MessageQueue> iter = set2.iterator();
         boolean isEqual = true;
         while (iter.hasNext()) {
             if (!set1.contains(iter.next())) {