You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by do...@apache.org on 2021/11/12 02:33:23 UTC
[rocketmq] branch 5.0.0-alpha-static-topic updated: Polish typo
This is an automated email from the ASF dual-hosted git repository.
dongeforever pushed a commit to branch 5.0.0-alpha-static-topic
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-alpha-static-topic by this push:
new fdbc7ff Polish typo
fdbc7ff is described below
commit fdbc7ffd89d06fa6786e40ab8f326e172c1a584b
Author: dongeforever <do...@apache.org>
AuthorDate: Fri Nov 12 10:32:17 2021 +0800
Polish typo
---
.../java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index 34f9aad..ee7b31c 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -647,7 +647,7 @@ public class AdminBrokerProcessor extends AsyncNettyRequestProcessor implements
requestHeader.setTimestamp(timestamp);
requestHeader.setQueueId(item.getQueueId());
RpcRequest rpcRequest = new RpcRequest(RequestCode.SEARCH_OFFSET_BY_TIMESTAMP, requestHeader, null);
- RpcResponse rpcResponse = this.brokerController.getBrokerOuterAPI().pullMessage(item.getBname(), rpcRequest, this.brokerController.getBrokerConfig().getForwardTimeout());
+ RpcResponse rpcResponse = this.brokerController.getBrokerOuterAPI().searchOffset(item.getBname(), rpcRequest, this.brokerController.getBrokerConfig().getForwardTimeout());
if (rpcResponse.getException() != null) {
throw rpcResponse.getException();
}