diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java index c9b39946c07f64d8322c2617fc7431bbb1f9d828..b2e7294bf32e6489e1dfced51dbbdeeb066a717a 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java @@ -199,11 +199,12 @@ public abstract class NettyRemotingAbstract { @Override public void run() { try { - doBeforeRpcHooks(RemotingHelper.parseChannelRemoteAddr(ctx.channel()), cmd); + String remoteAddr = RemotingHelper.parseChannelRemoteAddr(ctx.channel()); + doBeforeRpcHooks(remoteAddr, cmd); final RemotingResponseCallback callback = new RemotingResponseCallback() { @Override public void callback(RemotingCommand response) { - doAfterRpcHooks(RemotingHelper.parseChannelRemoteAddr(ctx.channel()), cmd, response); + doAfterRpcHooks(remoteAddr, cmd, response); if (!cmd.isOnewayRPC()) { if (response != null) { response.setOpaque(opaque);