(rocketmq) branch develop updated: [ISSUE #10021] Optimize consumer type check with EnumSet (#10022)

[lizhimin]

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

lizhimin 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 3a184c3e9e [ISSUE #10021] Optimize consumer type check with EnumSet 
(#10022)
3a184c3e9e is described below

commit 3a184c3e9e5f442d56d3146e165d659241e63517
Author: yx9o <yangx_s...@163.com>
AuthorDate: Fri Jan 30 10:05:48 2026 +0800

    [ISSUE #10021] Optimize consumer type check with EnumSet (#10022)
---
 .../authorization/builder/DefaultAuthorizationContextBuilder.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java
 
b/auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java
index b0080084f0..f462aabc0d 100644
--- 
a/auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java
+++ 
b/auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java
@@ -39,6 +39,7 @@ import java.lang.reflect.Field;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
+import java.util.EnumSet;
 import java.util.HashMap;
 import java.util.List;
 import org.apache.commons.collections.CollectionUtils;
@@ -85,6 +86,8 @@ public class DefaultAuthorizationContextBuilder implements 
AuthorizationContextB
     private static final String B = "b";
     private static final String CONSUMER_GROUP = "consumerGroup";
     private final AuthConfig authConfig;
+    private static final EnumSet<ClientType> CONSUMER_CLIENT_TYPES =
+            EnumSet.of(ClientType.PUSH_CONSUMER, ClientType.SIMPLE_CONSUMER, 
ClientType.PULL_CONSUMER);
 
     private final RequestHeaderRegistry requestHeaderRegistry;
 
@@ -438,8 +441,7 @@ public class DefaultAuthorizationContextBuilder implements 
AuthorizationContextB
     }
 
     private boolean isConsumerClientType(ClientType clientType) {
-        return Arrays.asList(ClientType.PUSH_CONSUMER, 
ClientType.SIMPLE_CONSUMER, ClientType.PULL_CONSUMER)
-            .contains(clientType);
+        return CONSUMER_CLIENT_TYPES.contains(clientType);
     }
 
     private static List<DefaultAuthorizationContext> newPubContext(Metadata 
metadata, apache.rocketmq.v2.Resource topic) {