This is an automated email from the ASF dual-hosted git repository. fuyou pushed a commit to branch issues-748 in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 51504dc515e9667ab4cca64a757a66d6ea7c7348 Author: 傅冲 <[email protected]> AuthorDate: Sat May 11 11:19:50 2024 +0800 fixed #748 --- .../java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java index 2ae5f5e4..7630fefb 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java @@ -122,7 +122,7 @@ public class ClientManagerImpl extends ClientManager { Runtime.getRuntime().availableProcessors(), 60, TimeUnit.SECONDS, - new LinkedBlockingQueue<>(), + new LinkedBlockingQueue<>(50000), new ThreadFactoryImpl("ClientAsyncWorker", clientIndex)); }
