You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by il...@apache.org on 2019/03/14 08:54:51 UTC
[incubator-dubbo] branch master updated: fix heartbeat internal
(#3579)
This is an automated email from the ASF dual-hosted git repository.
iluo 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 0c2232f fix heartbeat internal (#3579)
0c2232f is described below
commit 0c2232f3917eba133a8b9afe0808375a2dc4dc64
Author: 时无两丶 <44...@qq.com>
AuthorDate: Thu Mar 14 16:54:46 2019 +0800
fix heartbeat internal (#3579)
---
.../java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java
index 464087e..7ba4a63 100644
--- a/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java
+++ b/dubbo-remoting/dubbo-remoting-netty4/src/main/java/org/apache/dubbo/remoting/transport/netty4/NettyClient.java
@@ -78,7 +78,7 @@ public class NettyClient extends AbstractClient {
@Override
protected void initChannel(Channel ch) throws Exception {
- int heartbeatInterval = UrlUtils.getIdleTimeout(getUrl());
+ int heartbeatInterval = UrlUtils.getHeartbeat(getUrl());
NettyCodecAdapter adapter = new NettyCodecAdapter(getCodec(), getUrl(), NettyClient.this);
ch.pipeline()//.addLast("logging",new LoggingHandler(LogLevel.INFO))//for debug
.addLast("decoder", adapter.getDecoder())