You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by hu...@apache.org on 2018/07/16 23:34:08 UTC
[incubator-dubbo] branch master updated: Make channel final because
of using in inner class. (#2086)
This is an automated email from the ASF dual-hosted git repository.
huxing pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new cc56f48 Make channel final because of using in inner class. (#2086)
cc56f48 is described below
commit cc56f4849e6fd20ef9557f493d63893c72fd0a56
Author: 时无两丶 <44...@qq.com>
AuthorDate: Tue Jul 17 07:33:48 2018 +0800
Make channel final because of using in inner class. (#2086)
---
.../dubbo/remoting/exchange/support/header/HeaderExchangeHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeHandler.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeHandler.java
index 2110813..5532620 100644
--- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeHandler.java
+++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeHandler.java
@@ -77,7 +77,7 @@ public class HeaderExchangeHandler implements ChannelHandlerDelegate {
}
}
- void handleRequest(ExchangeChannel channel, Request req) throws RemotingException {
+ void handleRequest(final ExchangeChannel channel, Request req) throws RemotingException {
Response res = new Response(req.getId(), req.getVersion());
if (req.isBroken()) {
Object data = req.getData();
@@ -183,7 +183,7 @@ public class HeaderExchangeHandler implements ChannelHandlerDelegate {
@Override
public void received(Channel channel, Object message) throws RemotingException {
channel.setAttribute(KEY_READ_TIMESTAMP, System.currentTimeMillis());
- ExchangeChannel exchangeChannel = HeaderExchangeChannel.getOrAddChannel(channel);
+ final ExchangeChannel exchangeChannel = HeaderExchangeChannel.getOrAddChannel(channel);
try {
if (message instanceof Request) {
// handle request.