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 <[email protected]> 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() {
