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

[ISSUE #8966] Feat: add remote address information to acl perm error

Browse Source
This commit is contained in:
Humkum
2024-12-02 10:04:17 +08:00
committed by GitHub
parent 93d7e80a97
commit ea1228a30a
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
+3 -2
View File
@@ -320,9 +320,10 @@ public abstract class NettyRemotingAbstract {
return () -> {
Exception exception = null;
RemotingCommand response;
String remoteAddr = null;
try {
String remoteAddr = RemotingHelper.parseChannelRemoteAddr(ctx.channel());
remoteAddr = RemotingHelper.parseChannelRemoteAddr(ctx.channel());
try {
doBeforeRpcHooks(remoteAddr, cmd);
} catch (AbortProcessException e) {
@@ -359,7 +360,7 @@ public abstract class NettyRemotingAbstract {
response.setOpaque(opaque);
writeResponse(ctx.channel(), cmd, response);
} catch (Throwable e) {
log.error("process request exception", e);
log.error("process request exception, remoteAddr: {}", remoteAddr, e);
log.error(cmd.toString());
if (!cmd.isOnewayRPC()) {