This is an automated email from the ASF dual-hosted git repository. albumenj pushed a commit to branch 3.3 in repository https://gitbox.apache.org/repos/asf/dubbo.git
commit a1bfa7b8f7c5e2870a03983f44d0f26184b68cbb Author: Albumen Kevin <[email protected]> AuthorDate: Sun Feb 4 17:26:53 2024 +0800 Fix style --- .../main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java | 1 - .../dubbo/remoting/api/pu/AbstractPortUnificationServer.java | 7 +++---- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java b/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java index 7e74a769fe..78b85744c7 100644 --- a/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java +++ b/dubbo-common/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java @@ -55,7 +55,6 @@ import static org.apache.dubbo.common.constants.CommonConstants.RELEASE_KEY; import static org.apache.dubbo.common.constants.CommonConstants.TAG_KEY; import static org.apache.dubbo.common.constants.CommonConstants.TIMESTAMP_KEY; import static org.apache.dubbo.common.constants.LoggerCodeConstants.CONFIG_NO_METHOD_FOUND; -import static org.apache.dubbo.common.constants.MetricsConstants.PROTOCOL_PROMETHEUS; import static org.apache.dubbo.config.Constants.DEFAULT_NATIVE_PROXY; /** diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/pu/AbstractPortUnificationServer.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/pu/AbstractPortUnificationServer.java index e456ef9766..4431e8e9b9 100644 --- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/pu/AbstractPortUnificationServer.java +++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/api/pu/AbstractPortUnificationServer.java @@ -18,14 +18,13 @@ package org.apache.dubbo.remoting.api.pu; import org.apache.dubbo.common.URL; import org.apache.dubbo.common.extension.ExtensionLoader; +import org.apache.dubbo.common.utils.StringUtils; import org.apache.dubbo.remoting.ChannelHandler; import org.apache.dubbo.remoting.RemotingException; import org.apache.dubbo.remoting.api.WireProtocol; import org.apache.dubbo.remoting.transport.AbstractServer; -import java.util.ArrayList; import java.util.Arrays; -import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.function.Function; @@ -57,8 +56,8 @@ public abstract class AbstractPortUnificationServer extends AbstractServer { public AbstractPortUnificationServer(URL url, ChannelHandler handler) throws RemotingException { super(url, handler); ExtensionLoader<WireProtocol> loader = url.getOrDefaultFrameworkModel().getExtensionLoader(WireProtocol.class); - Map<String, WireProtocol> protocols = extensionLoader.getActivateExtension(url, new String[0]).stream() - .collect(Collectors.toConcurrentMap(extensionLoader::getExtensionName, Function.identity())) + Map<String, WireProtocol> protocols = loader.getActivateExtension(url, new String[0]).stream() + .collect(Collectors.toConcurrentMap(loader::getExtensionName, Function.identity())); // load extra protocols String extraProtocols = url.getParameter(EXT_PROTOCOL); if (StringUtils.isNotEmpty(extraProtocols)) {
