提交 1de18a12 编写于 作者: Mr_wangxin's avatar Mr_wangxin 提交者: dongeforever

fix typo in ClientConfig

上级 02acf1a0
...@@ -32,7 +32,7 @@ public class ClientConfig { ...@@ -32,7 +32,7 @@ public class ClientConfig {
/** /**
* Pulling topic information interval from the named server * 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 * Heartbeat interval in microseconds with message broker
*/ */
...@@ -86,7 +86,7 @@ public class ClientConfig { ...@@ -86,7 +86,7 @@ public class ClientConfig {
this.clientIP = cc.clientIP; this.clientIP = cc.clientIP;
this.instanceName = cc.instanceName; this.instanceName = cc.instanceName;
this.clientCallbackExecutorThreads = cc.clientCallbackExecutorThreads; this.clientCallbackExecutorThreads = cc.clientCallbackExecutorThreads;
this.pollNameServerInteval = cc.pollNameServerInteval; this.pollNameServerInterval = cc.pollNameServerInterval;
this.heartbeatBrokerInterval = cc.heartbeatBrokerInterval; this.heartbeatBrokerInterval = cc.heartbeatBrokerInterval;
this.persistConsumerOffsetInterval = cc.persistConsumerOffsetInterval; this.persistConsumerOffsetInterval = cc.persistConsumerOffsetInterval;
this.unitMode = cc.unitMode; this.unitMode = cc.unitMode;
...@@ -100,7 +100,7 @@ public class ClientConfig { ...@@ -100,7 +100,7 @@ public class ClientConfig {
cc.clientIP = clientIP; cc.clientIP = clientIP;
cc.instanceName = instanceName; cc.instanceName = instanceName;
cc.clientCallbackExecutorThreads = clientCallbackExecutorThreads; cc.clientCallbackExecutorThreads = clientCallbackExecutorThreads;
cc.pollNameServerInteval = pollNameServerInteval; cc.pollNameServerInterval = pollNameServerInterval;
cc.heartbeatBrokerInterval = heartbeatBrokerInterval; cc.heartbeatBrokerInterval = heartbeatBrokerInterval;
cc.persistConsumerOffsetInterval = persistConsumerOffsetInterval; cc.persistConsumerOffsetInterval = persistConsumerOffsetInterval;
cc.unitMode = unitMode; cc.unitMode = unitMode;
...@@ -125,12 +125,12 @@ public class ClientConfig { ...@@ -125,12 +125,12 @@ public class ClientConfig {
this.clientCallbackExecutorThreads = clientCallbackExecutorThreads; this.clientCallbackExecutorThreads = clientCallbackExecutorThreads;
} }
public int getPollNameServerInteval() { public int getPollNameServerInterval() {
return pollNameServerInteval; return pollNameServerInterval;
} }
public void setPollNameServerInteval(int pollNameServerInteval) { public void setPollNameServerInterval(int pollNameServerInterval) {
this.pollNameServerInteval = pollNameServerInteval; this.pollNameServerInterval = pollNameServerInterval;
} }
public int getHeartbeatBrokerInterval() { public int getHeartbeatBrokerInterval() {
...@@ -176,7 +176,7 @@ public class ClientConfig { ...@@ -176,7 +176,7 @@ public class ClientConfig {
@Override @Override
public String toString() { public String toString() {
return "ClientConfig [namesrvAddr=" + namesrvAddr + ", clientIP=" + clientIP + ", instanceName=" + instanceName return "ClientConfig [namesrvAddr=" + namesrvAddr + ", clientIP=" + clientIP + ", instanceName=" + instanceName
+ ", clientCallbackExecutorThreads=" + clientCallbackExecutorThreads + ", pollNameServerInteval=" + pollNameServerInteval + ", clientCallbackExecutorThreads=" + clientCallbackExecutorThreads + ", pollNameServerInterval=" + pollNameServerInterval
+ ", heartbeatBrokerInterval=" + heartbeatBrokerInterval + ", persistConsumerOffsetInterval=" + ", heartbeatBrokerInterval=" + heartbeatBrokerInterval + ", persistConsumerOffsetInterval="
+ persistConsumerOffsetInterval + ", unitMode=" + unitMode + ", unitName=" + unitName + ", vipChannelEnabled=" + persistConsumerOffsetInterval + ", unitMode=" + unitMode + ", unitName=" + unitName + ", vipChannelEnabled="
+ vipChannelEnabled + "]"; + vipChannelEnabled + "]";
......
...@@ -275,7 +275,7 @@ public class MQClientInstance { ...@@ -275,7 +275,7 @@ public class MQClientInstance {
log.error("ScheduledTask updateTopicRouteInfoFromNameServer exception", e); log.error("ScheduledTask updateTopicRouteInfoFromNameServer exception", e);
} }
} }
}, 10, this.clientConfig.getPollNameServerInteval(), TimeUnit.MILLISECONDS); }, 10, this.clientConfig.getPollNameServerInterval(), TimeUnit.MILLISECONDS);
this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() { this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册