From 66e5a91cf039d44b1918443a6afc56b54496eb2a Mon Sep 17 00:00:00 2001 From: kimi Date: Tue, 17 Jul 2012 11:33:42 +0800 Subject: [PATCH] =?UTF-8?q?DUBBO-122=20Provider=E7=9A=84=E7=BA=BF=E7=A8=8B?= =?UTF-8?q?=E6=B1=A0=E7=9B=91=E6=8E=A7=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../transport/dispather/WrappedChannelHandler.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/transport/dispather/WrappedChannelHandler.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/transport/dispather/WrappedChannelHandler.java index 98b1348d5..e7abf1722 100644 --- a/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/transport/dispather/WrappedChannelHandler.java +++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/com/alibaba/dubbo/remoting/transport/dispather/WrappedChannelHandler.java @@ -48,14 +48,12 @@ public class WrappedChannelHandler implements ChannelHandlerDelegate { this.url = url; executor = (ExecutorService) ExtensionLoader.getExtensionLoader(ThreadPool.class).getAdaptiveExtension().getExecutor(url); - if (Constants.PROVIDER_SIDE.equalsIgnoreCase(url.getParameter(Constants.SIDE_KEY))) { - DataStore dataStore = ExtensionLoader.getExtensionLoader(DataStore.class).getDefaultExtension(); - dataStore.put(Constants.EXECUTOR_SERVICE_COMPONENT_KEY, Integer.toString(url.getPort()), executor); - } + String componentKey = Constants.EXECUTOR_SERVICE_COMPONENT_KEY; if (Constants.CONSUMER_SIDE.equalsIgnoreCase(url.getParameter(Constants.SIDE_KEY))) { - DataStore dataStore = ExtensionLoader.getExtensionLoader(DataStore.class).getDefaultExtension(); - dataStore.put(Constants.CONSUMER_SIDE, Integer.toString(url.getPort()), executor); + componentKey = Constants.CONSUMER_SIDE; } + DataStore dataStore = ExtensionLoader.getExtensionLoader(DataStore.class).getDefaultExtension(); + dataStore.put(componentKey, Integer.toString(url.getPort()), executor); } public void close() { -- GitLab