[rocketmq-clients] branch master updated: Disable keep alive for gRPC channel

[aa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new ba3c5c8e Disable keep alive for gRPC channel
ba3c5c8e is described below

commit ba3c5c8e8a5fe1a0f060b86f35dfcd51408978f1
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Thu Dec 8 14:40:00 2022 +0800

    Disable keep alive for gRPC channel
---
 .../src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java | 1 -
 1 file changed, 1 deletion(-)

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java
index 310b762e..387085f4 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java
@@ -82,7 +82,6 @@ public class RpcClientImpl implements RpcClient {
         final NettyChannelBuilder channelBuilder =
             NettyChannelBuilder.forTarget(endpoints.getGrpcTarget())
                 .withOption(ChannelOption.CONNECT_TIMEOUT_MILLIS, CONNECT_TIMEOUT_MILLIS)
-                .keepAliveTime(KEEP_ALIVE_DURATION.toNanos(), TimeUnit.NANOSECONDS)
                 .maxInboundMessageSize(GRPC_MAX_MESSAGE_SIZE)
                 .intercept(LoggingInterceptor.getInstance())
                 .sslContext(sslContext);