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

albumenj pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/3.0 by this push:
     new babd7b1  [3.0] change local invokers from Collections.singletonList to 
ArrayList (#8997)
babd7b1 is described below

commit babd7b14b446c515519d6bf093e7fb14e3f2fc14
Author: zrlw <[email protected]>
AuthorDate: Sat Oct 9 16:03:27 2021 +0800

    [3.0] change local invokers from Collections.singletonList to ArrayList 
(#8997)
    
    * change local invokers from Collections.singletonList to ArrayList
    
    * remove useless import
---
 .../src/main/java/org/apache/dubbo/config/ReferenceConfig.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
 
b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
index 5c8639d..47d2c82 100644
--- 
a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
+++ 
b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ReferenceConfig.java
@@ -51,7 +51,6 @@ import org.apache.dubbo.rpc.support.ProtocolUtils;
 
 import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
@@ -399,15 +398,16 @@ public class ReferenceConfig<T> extends 
ReferenceConfigBase<T> {
      *
      * @param referenceParameters
      */
+    @SuppressWarnings({"unchecked", "rawtypes"})
     private void createInvokerForLocal(Map<String, String> 
referenceParameters) {
         URL url = new ServiceConfigURL(LOCAL_PROTOCOL, LOCALHOST_VALUE, 0, 
interfaceClass.getName()).addParameters(referenceParameters);
         url = url.setScopeModel(getScopeModel());
         url = url.setServiceModel(consumerModel);
         Invoker<?> withFilter = protocolSPI.refer(interfaceClass, url);
-
         // Local Invoke ( Support Cluster Filter / Filter )
-        StaticDirectory<?> directory = new StaticDirectory<>(url, 
Collections.singletonList(withFilter));
-        invoker = Cluster.getCluster(url.getScopeModel(), 
Cluster.DEFAULT).join(directory, true);
+        List<Invoker<?>> invokers = new ArrayList<>();
+        invokers.add(withFilter);
+        invoker = Cluster.getCluster(url.getScopeModel(), 
Cluster.DEFAULT).join(new StaticDirectory(url, invokers), true);
 
         if (logger.isInfoEnabled()) {
             logger.info("Using in jvm service " + interfaceClass.getName());

Reply via email to