You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/02/28 23:48:54 UTC
[rocketmq] branch develop updated: [ISSUE #3898]fix the spell in MQClientAPIImpl (#3899)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 7281b5d [ISSUE #3898]fix the spell in MQClientAPIImpl (#3899)
7281b5d is described below
commit 7281b5d9a0db15e5ec1ab9e3444091e7022f65fb
Author: zhangjidi2016 <10...@qq.com>
AuthorDate: Tue Mar 1 07:48:36 2022 +0800
[ISSUE #3898]fix the spell in MQClientAPIImpl (#3899)
Co-authored-by: zhangjidi2016 <zh...@cmss.chinamobile.com>
---
.../src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java | 2 +-
.../java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index 8506432..8dc73ad 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -1022,7 +1022,7 @@ public class MQClientAPIImpl {
this.remotingClient.invokeOneway(MixAll.brokerVIPChannel(this.clientConfig.isVipChannelEnabled(), addr), request, timeoutMillis);
}
- public int sendHearbeat(
+ public int sendHeartbeat(
final String addr,
final HeartbeatData heartbeatData,
final long timeoutMillis
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
index 0cc5e3e..d5b9097 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
@@ -555,7 +555,7 @@ public class MQClientInstance {
}
try {
- int version = this.mQClientAPIImpl.sendHearbeat(addr, heartbeatData, clientConfig.getMqClientApiTimeout());
+ int version = this.mQClientAPIImpl.sendHeartbeat(addr, heartbeatData, clientConfig.getMqClientApiTimeout());
if (!this.brokerVersionTable.containsKey(brokerName)) {
this.brokerVersionTable.put(brokerName, new HashMap<String, Integer>(4));
}