commit 8cd5c27869a077e2bae63cf91f06c29921874e22
author chengxy <chengxy@qk.com> Thu Jun 15 15:22:41 2023 +0800
committer shenlin <2011shenlin@gmail.com> Mon Jun 19 09:45:33 2023 +0800
tree 49747351c8fc1065b77a9311af9f878e53db5ed0
parent 2a0770ce800815e692aa61eb046b14fe1dde1d7d

fix resourceOwnerIds fetch exception

infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java

diff --git a/infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java b/infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java
index 5738a75..db99570 100644
--- a/infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java
+++ b/infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java
@@ -17,10 +17,12 @@
 
 package org.apache.rocketmq.eventbridge.infrastructure.validate;
 
+import org.springframework.http.HttpHeaders;
 import org.springframework.http.server.reactive.ServerHttpRequest;
 import reactor.util.context.Context;
 
 import java.util.List;
+import java.util.Map;
 
 import static org.apache.rocketmq.eventbridge.enums.props.Constants.HEADER_KEY_RESOURCE_OWNER_ACCOUNT_ID;
 
@@ -32,7 +34,7 @@
     @Override
     public Context validate(ServerHttpRequest request, Context ctx) {
         String resourceOwnerId = "default";
-        List<String> resourceOwnerIds = request.getHeaders().get(HEADER_KEY_RESOURCE_OWNER_ACCOUNT_ID);
+        List<String> resourceOwnerIds = request.getHeaders().get(HEADER_KEY_RESOURCE_OWNER_ACCOUNT_ID.getName());
         if (resourceOwnerIds != null && !resourceOwnerIds.isEmpty()) {
             //throw new EventBridgeException(DefaultErrorCode.LoginFailed);
             resourceOwnerId = resourceOwnerIds.get(0);