Skip to content

Commit d933eeb

Browse files
vesenselizhanhui
authored andcommitted
fix typo in ClientConfig
1 parent 01a0eb0 commit d933eeb

File tree

2 files changed

+9
-9
lines changed

2 files changed

+9
-9
lines changed

client/src/main/java/org/apache/rocketmq/client/ClientConfig.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public class ClientConfig {
3232
/**
3333
* Pulling topic information interval from the named server
3434
*/
35-
private int pollNameServerInteval = 1000 * 30;
35+
private int pollNameServerInterval = 1000 * 30;
3636
/**
3737
* Heartbeat interval in microseconds with message broker
3838
*/
@@ -86,7 +86,7 @@ public void resetClientConfig(final ClientConfig cc) {
8686
this.clientIP = cc.clientIP;
8787
this.instanceName = cc.instanceName;
8888
this.clientCallbackExecutorThreads = cc.clientCallbackExecutorThreads;
89-
this.pollNameServerInteval = cc.pollNameServerInteval;
89+
this.pollNameServerInterval = cc.pollNameServerInterval;
9090
this.heartbeatBrokerInterval = cc.heartbeatBrokerInterval;
9191
this.persistConsumerOffsetInterval = cc.persistConsumerOffsetInterval;
9292
this.unitMode = cc.unitMode;
@@ -100,7 +100,7 @@ public ClientConfig cloneClientConfig() {
100100
cc.clientIP = clientIP;
101101
cc.instanceName = instanceName;
102102
cc.clientCallbackExecutorThreads = clientCallbackExecutorThreads;
103-
cc.pollNameServerInteval = pollNameServerInteval;
103+
cc.pollNameServerInterval = pollNameServerInterval;
104104
cc.heartbeatBrokerInterval = heartbeatBrokerInterval;
105105
cc.persistConsumerOffsetInterval = persistConsumerOffsetInterval;
106106
cc.unitMode = unitMode;
@@ -125,12 +125,12 @@ public void setClientCallbackExecutorThreads(int clientCallbackExecutorThreads)
125125
this.clientCallbackExecutorThreads = clientCallbackExecutorThreads;
126126
}
127127

128-
public int getPollNameServerInteval() {
129-
return pollNameServerInteval;
128+
public int getPollNameServerInterval() {
129+
return pollNameServerInterval;
130130
}
131131

132-
public void setPollNameServerInteval(int pollNameServerInteval) {
133-
this.pollNameServerInteval = pollNameServerInteval;
132+
public void setPollNameServerInterval(int pollNameServerInterval) {
133+
this.pollNameServerInterval = pollNameServerInterval;
134134
}
135135

136136
public int getHeartbeatBrokerInterval() {
@@ -176,7 +176,7 @@ public void setVipChannelEnabled(final boolean vipChannelEnabled) {
176176
@Override
177177
public String toString() {
178178
return "ClientConfig [namesrvAddr=" + namesrvAddr + ", clientIP=" + clientIP + ", instanceName=" + instanceName
179-
+ ", clientCallbackExecutorThreads=" + clientCallbackExecutorThreads + ", pollNameServerInteval=" + pollNameServerInteval
179+
+ ", clientCallbackExecutorThreads=" + clientCallbackExecutorThreads + ", pollNameServerInterval=" + pollNameServerInterval
180180
+ ", heartbeatBrokerInterval=" + heartbeatBrokerInterval + ", persistConsumerOffsetInterval="
181181
+ persistConsumerOffsetInterval + ", unitMode=" + unitMode + ", unitName=" + unitName + ", vipChannelEnabled="
182182
+ vipChannelEnabled + "]";

client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -275,7 +275,7 @@ public void run() {
275275
log.error("ScheduledTask updateTopicRouteInfoFromNameServer exception", e);
276276
}
277277
}
278-
}, 10, this.clientConfig.getPollNameServerInteval(), TimeUnit.MILLISECONDS);
278+
}, 10, this.clientConfig.getPollNameServerInterval(), TimeUnit.MILLISECONDS);
279279

280280
this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
281281

0 commit comments

Comments
 (0)