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 <[email protected]> Authored: Fri Mar 24 13:38:55 2017 +0800 Committer: dongeforever <[email protected]> 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() {
