opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-01 15:47:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #6019] simplified the PlainAccessResource parse method

Browse Source
This commit is contained in:
hardyfish
2023-02-11 13:10:31 +08:00
committed by GitHub
parent d3ebe02ccb
commit 4cfd54f533
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessResource.java
+4 -4
View File
@@ -178,14 +178,14 @@ public class PlainAccessResource implements AccessResource {
// Content
SortedMap<String, String> map = new TreeMap<>();
for (Map.Entry<String, String> entry : request.getExtFields().entrySet()) {
if (request.getVersion() <= MQVersion.Version.V4_9_3.ordinal() &&
MixAll.UNIQUE_MSG_QUERY_FLAG.equals(entry.getKey())) {
continue;
}
if (!SessionCredentials.SIGNATURE.equals(entry.getKey())) {
map.put(entry.getKey(), entry.getValue());
}
}
if (request.getVersion() <= MQVersion.Version.V4_9_3.ordinal()
&& map.containsKey(MixAll.UNIQUE_MSG_QUERY_FLAG)) {
map.remove(MixAll.UNIQUE_MSG_QUERY_FLAG);
}
accessResource.setContent(AclUtils.combineRequestContent(request, map));
return accessResource;
}