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

[ISSUE #3949] add log when write rejected response

Browse Source
This commit is contained in:
kaiyi.lk
2022-07-13 11:30:50 +08:00
committed by zhouxiang
parent 3bac7de043
commit 405f5aad83
2 changed files with 6 additions and 4 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
+6 -3
View File
@@ -349,7 +349,6 @@ public class GrpcMessagingApplication extends MessagingServiceGrpc.MessagingServ
@Override
public void onError(Throwable t) {
log.error("telemetry onError", t);
responseTelemetryCommand.onError(t);
}
@@ -400,8 +399,12 @@ public class GrpcMessagingApplication extends MessagingServiceGrpc.MessagingServ
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
if (r instanceof GrpcTask) {
GrpcTask grpcTask = (GrpcTask) r;
ResponseWriter.write(grpcTask.streamObserver, grpcTask.executeRejectResponse);
try {
GrpcTask grpcTask = (GrpcTask) r;
ResponseWriter.write(grpcTask.streamObserver, grpcTask.executeRejectResponse);
} catch (Throwable t) {
log.warn("write rejected error response failed", t);
}
}
}
}