diff --git a/broker/src/test/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessorTest.java b/broker/src/test/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessorTest.java
index 94fd8f560d1ff0a22baf037122cfb441dd9e34ff..85c775040f53ef6093e979c8c6adc53a3a36161f 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessorTest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessorTest.java
@@ -71,8 +71,7 @@ public class ReplyMessageProcessorTest {
     private MessageStore messageStore;
     @Mock
     private Channel channel;
-    @Mock
-    private TransactionalMessageService transactionMsgService;
+
     private String topic = "FooBar";
     private String group = "FooBarGroup";
     private ClientChannelInfo clientInfo;
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
index 5cac5e832a87fc63ecb55185603ca8665dce2b56..c57e49bb6111b550dba1f183441395d9ed523486 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
@@ -83,7 +83,7 @@ public class ClientRemotingProcessor implements NettyRequestProcessor {
                 return this.consumeMessageDirectly(ctx, request);
 
             case RequestCode.PUSH_REPLY_MESSAGE_TO_CLIENT:
-                return this.receiveReplyMssage(ctx, request);
+                return this.receiveReplyMessage(ctx, request);
             default:
                 break;
         }
@@ -222,7 +222,7 @@ public class ClientRemotingProcessor implements NettyRequestProcessor {
         return response;
     }
 
-    private RemotingCommand receiveReplyMssage(ChannelHandlerContext ctx,
+    private RemotingCommand receiveReplyMessage(ChannelHandlerContext ctx,
         RemotingCommand request) throws RemotingCommandException {
 
         final RemotingCommand response = RemotingCommand.createResponseCommand(null);
@@ -293,7 +293,9 @@ public class ClientRemotingProcessor implements NettyRequestProcessor {
                 requestResponseFuture.putResponseMessage(replyMsg);
             }
         } else {
-            log.warn(String.format("receive reply message, but not matched any request, CorrelationId: %s", correlationId));
+            String bornHost = replyMsg.getBornHostString();
+            log.warn(String.format("receive reply message, but not matched any request, CorrelationId: %s , reply from host: %s",
+                correlationId, bornHost));
         }
     }
 }