change class loader (#11312)

apache · Jan 17, 2023 · d5e9c58 · d5e9c58
1 parent 8cc3539
commit d5e9c58
Showing 1 changed file with 9 additions and 11 deletions.
diff --git a/...le/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ReflectionAbstractServerCall.java b/...le/src/main/java/org/apache/dubbo/rpc/protocol/tri/call/ReflectionAbstractServerCall.java
@@ -46,13 +46,13 @@ public class ReflectionAbstractServerCall extends AbstractServerCall {
     private List<MethodDescriptor> methodDescriptors;
 
     public ReflectionAbstractServerCall(Invoker<?> invoker,
-        ServerStream serverStream,
-        FrameworkModel frameworkModel,
-        String acceptEncoding,
-        String serviceName,
-        String methodName,
-        List<HeaderFilter> headerFilters,
-        Executor executor) {
+                                        ServerStream serverStream,
+                                        FrameworkModel frameworkModel,
+                                        String acceptEncoding,
+                                        String serviceName,
+                                        String methodName,
+                                        List<HeaderFilter> headerFilters,
+                                        Executor executor) {
         super(invoker, serverStream, frameworkModel,
             getServiceDescriptor(invoker.getUrl()),
             acceptEncoding, serviceName, methodName,
@@ -155,10 +155,8 @@ protected Object parseSingleMessage(byte[] data)
         if (isClosed()) {
             return null;
         }
-        if (serviceDescriptor != null) {
-            ClassLoadUtil.switchContextLoader(
-                serviceDescriptor.getServiceInterfaceClass().getClassLoader());
-        }
+        ClassLoadUtil.switchContextLoader(
+            invoker.getUrl().getServiceModel().getClassLoader());
         return packableMethod.getRequestUnpack().unpack(data);
     }