You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/12/09 11:53:46 UTC
[rocketmq] 05/26: [ISSUE #5485] test cases for client connection management
This is an automated email from the ASF dual-hosted git repository.
zhouxzhan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 6c8233043676f42205d24f59a9981ba5a9e54366
Author: kaiyi.lk <ka...@alibaba-inc.com>
AuthorDate: Wed Nov 9 11:37:36 2022 +0800
[ISSUE #5485] test cases for client connection management
---
.../test/java/org/apache/rocketmq/proxy/grpc/v2/BaseActivityTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/BaseActivityTest.java b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/BaseActivityTest.java
index 635e4b5f3..524945bd6 100644
--- a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/BaseActivityTest.java
+++ b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/BaseActivityTest.java
@@ -71,7 +71,7 @@ public class BaseActivityTest extends InitConfigTest {
metadata.put(InterceptorConstants.LOCAL_ADDRESS, LOCAL_ADDR);
when(messagingProcessor.getProxyRelayService()).thenReturn(proxyRelayService);
when(messagingProcessor.getMetadataService()).thenReturn(metadataService);
- grpcChannelManager = new GrpcChannelManager(messagingProcessor.getProxyRelayService());
+ grpcChannelManager = new GrpcChannelManager(messagingProcessor.getProxyRelayService(), grpcClientSettingsManager);
}
protected ProxyContext createContext() {