fixed #748 (#749)

apache · Jun 13, 2024 · 2046d47 · 2046d47
1 parent c8a685d
commit 2046d47
Showing 1 changed file with 1 addition and 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
@@ -122,7 +122,7 @@ public ClientManagerImpl(Client client) {
             Runtime.getRuntime().availableProcessors(),
             60,
             TimeUnit.SECONDS,
-            new LinkedBlockingQueue<>(),
+            new LinkedBlockingQueue<>(50000),
             new ThreadFactoryImpl("ClientAsyncWorker", clientIndex));
     }