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 2017/06/06 03:38:24 UTC
[04/51] [abbrv] incubator-rocketmq git commit: fix typo in
ClientConfig
fix typo in ClientConfig
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/1de18a12
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/1de18a12
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/1de18a12
Branch: refs/heads/master
Commit: 1de18a126c10869b03b730ff8436395c05983f6e
Parents: 02acf1a
Author: vesense <be...@163.com>
Authored: Fri Mar 24 13:38:55 2017 +0800
Committer: dongeforever <zh...@yeah.net>
Committed: Tue Jun 6 11:37:29 2017 +0800
----------------------------------------------------------------------
.../org/apache/rocketmq/client/ClientConfig.java | 16 ++++++++--------
.../client/impl/factory/MQClientInstance.java | 2 +-
2 files changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/1de18a12/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
index 69ebfef..950d756 100644
--- a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
+++ b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
@@ -32,7 +32,7 @@ public class ClientConfig {
/**
* Pulling topic information interval from the named server
*/
- private int pollNameServerInteval = 1000 * 30;
+ private int pollNameServerInterval = 1000 * 30;
/**
* Heartbeat interval in microseconds with message broker
*/
@@ -86,7 +86,7 @@ public class ClientConfig {
this.clientIP = cc.clientIP;
this.instanceName = cc.instanceName;
this.clientCallbackExecutorThreads = cc.clientCallbackExecutorThreads;
- this.pollNameServerInteval = cc.pollNameServerInteval;
+ this.pollNameServerInterval = cc.pollNameServerInterval;
this.heartbeatBrokerInterval = cc.heartbeatBrokerInterval;
this.persistConsumerOffsetInterval = cc.persistConsumerOffsetInterval;
this.unitMode = cc.unitMode;
@@ -100,7 +100,7 @@ public class ClientConfig {
cc.clientIP = clientIP;
cc.instanceName = instanceName;
cc.clientCallbackExecutorThreads = clientCallbackExecutorThreads;
- cc.pollNameServerInteval = pollNameServerInteval;
+ cc.pollNameServerInterval = pollNameServerInterval;
cc.heartbeatBrokerInterval = heartbeatBrokerInterval;
cc.persistConsumerOffsetInterval = persistConsumerOffsetInterval;
cc.unitMode = unitMode;
@@ -125,12 +125,12 @@ public class ClientConfig {
this.clientCallbackExecutorThreads = clientCallbackExecutorThreads;
}
- public int getPollNameServerInteval() {
- return pollNameServerInteval;
+ public int getPollNameServerInterval() {
+ return pollNameServerInterval;
}
- public void setPollNameServerInteval(int pollNameServerInteval) {
- this.pollNameServerInteval = pollNameServerInteval;
+ public void setPollNameServerInterval(int pollNameServerInterval) {
+ this.pollNameServerInterval = pollNameServerInterval;
}
public int getHeartbeatBrokerInterval() {
@@ -176,7 +176,7 @@ public class ClientConfig {
@Override
public String toString() {
return "ClientConfig [namesrvAddr=" + namesrvAddr + ", clientIP=" + clientIP + ", instanceName=" + instanceName
- + ", clientCallbackExecutorThreads=" + clientCallbackExecutorThreads + ", pollNameServerInteval=" + pollNameServerInteval
+ + ", clientCallbackExecutorThreads=" + clientCallbackExecutorThreads + ", pollNameServerInterval=" + pollNameServerInterval
+ ", heartbeatBrokerInterval=" + heartbeatBrokerInterval + ", persistConsumerOffsetInterval="
+ persistConsumerOffsetInterval + ", unitMode=" + unitMode + ", unitName=" + unitName + ", vipChannelEnabled="
+ vipChannelEnabled + "]";
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/1de18a12/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
----------------------------------------------------------------------
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 7b14860..11266c4 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
@@ -275,7 +275,7 @@ public class MQClientInstance {
log.error("ScheduledTask updateTopicRouteInfoFromNameServer exception", e);
}
}
- }, 10, this.clientConfig.getPollNameServerInteval(), TimeUnit.MILLISECONDS);
+ }, 10, this.clientConfig.getPollNameServerInterval(), TimeUnit.MILLISECONDS);
this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {