opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 13:49:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #3949] v2 support

Browse Source
This commit is contained in:
kaiyi.lk
2022-07-13 11:29:36 +08:00
committed by zhouxiang
parent 9fe1bbc4df
commit 20e9bdd3e4
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
+4 -4
View File
@@ -83,7 +83,7 @@ public class GrpcMessagingApplication extends MessagingServiceGrpc.MessagingServ
config.getGrpcProducerThreadPoolNums(),
1,
TimeUnit.MINUTES,
"GrpcRouteThreadPool",
"GrpcProducerThreadPool",
config.getGrpcProducerThreadQueueCapacity()
);
this.consumerThreadPoolExecutor = ThreadPoolMonitor.createAndMonitor(
@@ -91,7 +91,7 @@ public class GrpcMessagingApplication extends MessagingServiceGrpc.MessagingServ
config.getGrpcConsumerThreadPoolNums(),
1,
TimeUnit.MINUTES,
"GrpcRouteThreadPool",
"GrpcConsumerThreadPool",
config.getGrpcConsumerThreadQueueCapacity()
);
this.clientManagerThreadPoolExecutor = ThreadPoolMonitor.createAndMonitor(
@@ -99,7 +99,7 @@ public class GrpcMessagingApplication extends MessagingServiceGrpc.MessagingServ
config.getGrpcClientManagerThreadPoolNums(),
1,
TimeUnit.MINUTES,
"GrpcRouteThreadPool",
"GrpcClientManagerThreadPool",
config.getGrpcClientManagerThreadQueueCapacity()
);
this.transactionThreadPoolExecutor = ThreadPoolMonitor.createAndMonitor(
@@ -107,7 +107,7 @@ public class GrpcMessagingApplication extends MessagingServiceGrpc.MessagingServ
config.getGrpcTransactionThreadPoolNums(),
1,
TimeUnit.MINUTES,
"GrpcRouteThreadPool",
"GrpcTransactionThreadPool",
config.getGrpcTransactionThreadQueueCapacity()
);
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java
+1 -1
View File
@@ -63,7 +63,7 @@ public class ReceiveMessageActivity extends AbstractMessingActivity {
pollTime = timeRemaining;
}
if (pollTime <= 0) {
writer.write(proxyContext, Code.MESSAGE_NOT_FOUND, "no new message");
writer.write(proxyContext, Code.MESSAGE_NOT_FOUND, "time remaining is too small");
return;
}