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/07/22 08:34:28 UTC

[dubbo] branch master updated: unused connectionManager in RestProtocol (#4614)

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/dubbo.git


The following commit(s) were added to refs/heads/master by this push:
     new 443b6ff  unused connectionManager in RestProtocol (#4614)
443b6ff is described below

commit 443b6ff49f5ee0670c10e559c8adb30ac6206bc2
Author: finalcola <84...@qq.com>
AuthorDate: Mon Jul 22 16:34:16 2019 +0800

    unused connectionManager in RestProtocol (#4614)
---
 .../src/main/java/org/apache/dubbo/rpc/protocol/rest/RestProtocol.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/RestProtocol.java b/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/RestProtocol.java
index c433b00..40a09da 100644
--- a/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/RestProtocol.java
+++ b/dubbo-rpc/dubbo-rpc-rest/src/main/java/org/apache/dubbo/rpc/protocol/rest/RestProtocol.java
@@ -161,6 +161,7 @@ public class RestProtocol extends AbstractProxyProtocol {
                 .build();
 
         CloseableHttpClient httpClient = HttpClientBuilder.create()
+                .setConnectionManager(connectionManager)
                 .setKeepAliveStrategy((response, context) -> {
                     HeaderElementIterator it = new BasicHeaderElementIterator(response.headerIterator(HTTP.CONN_KEEP_ALIVE));
                     while (it.hasNext()) {