Skip to content

Commit 5416a17

Browse files
committed
AJ-817: rename param from resubTimeout to resubscribeInterval
1 parent af52197 commit 5416a17

File tree

4 files changed

+17
-17
lines changed

4 files changed

+17
-17
lines changed

src/com/xxdb/streaming/client/Daemon.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ public void run() {
165165
dispatcher.activeCloseConnection(s);
166166
for (String topic : dispatcher.getAllTopicsBySite(site)) {
167167
System.out.println("Daemon need reconnect: " + topic);
168-
// reconnect every info.resubscribeTimeout ms
168+
// reconnect every info.resubscribeInterval ms
169169
if (System.currentTimeMillis() - AbstractClient.lastExceptionTopicTimeMap.get(topic) <= AbstractClient.resubscribeInterval)
170170
continue;
171171

@@ -175,7 +175,7 @@ public void run() {
175175
Site s = dispatcher.getSiteByName(site);
176176
dispatcher.activeCloseConnection(s);
177177
for (String topic : dispatcher.getAllTopicsBySite(site)) {
178-
// reconnect every info.resubscribeTimeout ms
178+
// reconnect every info.resubscribeInterval ms
179179
if (System.currentTimeMillis() - AbstractClient.lastExceptionTopicTimeMap.get(topic) <= AbstractClient.resubscribeInterval)
180180
continue;
181181

src/com/xxdb/streaming/client/PollingClient.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -89,12 +89,12 @@ public TopicPoller subscribe(String host, int port, String tableName, String act
8989
return topicPoller;
9090
}
9191

92-
public TopicPoller subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeTimeout, boolean subOnce) throws IOException {
93-
if (resubscribeTimeout < 0)
94-
// resubscribeTimeout default: 100ms
95-
resubscribeTimeout = 100;
92+
public TopicPoller subscribe(String host, int port, String tableName, String actionName, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeInterval, boolean subOnce) throws IOException {
93+
if (resubscribeInterval < 0)
94+
// resubscribeInterval default: 100ms
95+
resubscribeInterval = 100;
9696

97-
BlockingQueue<List<IMessage>> queue = subscribeInternal(host, port, tableName, actionName, (MessageHandler) null, offset, reconnect, filter, deserializer, false, userName, passWord, msgAsTable, backupSites, resubscribeTimeout, subOnce);
97+
BlockingQueue<List<IMessage>> queue = subscribeInternal(host, port, tableName, actionName, (MessageHandler) null, offset, reconnect, filter, deserializer, false, userName, passWord, msgAsTable, backupSites, resubscribeInterval, subOnce);
9898
topicPoller = new TopicPoller(queue);
9999
return topicPoller;
100100
}

src/com/xxdb/streaming/client/ThreadPooledClient.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -193,12 +193,12 @@ public void subscribe(String host, int port, String tableName, String actionName
193193
}
194194
}
195195

196-
public void subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeTimeout, boolean subOnce) throws IOException {
197-
if (resubscribeTimeout < 0)
198-
// resubscribeTimeout default: 100ms
199-
resubscribeTimeout = 100;
196+
public void subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeInterval, boolean subOnce) throws IOException {
197+
if (resubscribeInterval < 0)
198+
// resubscribeInterval default: 100ms
199+
resubscribeInterval = 100;
200200

201-
BlockingQueue<List<IMessage>> queue = subscribeInternal(host, port, tableName, actionName, handler, offset, reconnect, filter, deserializer, allowExistTopic, userName, passWord, msgAsTable, backupSites, resubscribeTimeout, subOnce);
201+
BlockingQueue<List<IMessage>> queue = subscribeInternal(host, port, tableName, actionName, handler, offset, reconnect, filter, deserializer, allowExistTopic, userName, passWord, msgAsTable, backupSites, resubscribeInterval, subOnce);
202202
String topicStr = host + ":" + port + "/" + tableName + "/" + actionName;
203203
synchronized (queueHandlers) {
204204
queueHandlers.put(tableNameToTrueTopic.get(topicStr), new QueueHandlerBinder(queue, handler));

src/com/xxdb/streaming/client/ThreadedClient.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -237,15 +237,15 @@ public void subscribe(String host, int port, String tableName, String actionName
237237
}
238238
}
239239

240-
public void subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle, String userName, String password, List<String> backupSites, int resubscribeTimeout, boolean subOnce) throws IOException {
240+
public void subscribe(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, int batchSize, int throttle, String userName, String password, List<String> backupSites, int resubscribeInterval, boolean subOnce) throws IOException {
241241
if(batchSize<=0)
242242
throw new IllegalArgumentException("BatchSize must be greater than zero");
243243
if(throttle<0)
244244
throw new IllegalArgumentException("Throttle must be greater than or equal to zero");
245-
if (resubscribeTimeout < 0)
246-
// resubscribeTimeout default: 100ms
247-
resubscribeTimeout = 100;
248-
BlockingQueue<List<IMessage>> queue = subscribeInternal(host, port, tableName, actionName, handler, offset, reconnect, filter, deserializer, allowExistTopic, userName, password, false, backupSites, resubscribeTimeout, subOnce);
245+
if (resubscribeInterval < 0)
246+
// resubscribeInterval default: 100ms
247+
resubscribeInterval = 100;
248+
BlockingQueue<List<IMessage>> queue = subscribeInternal(host, port, tableName, actionName, handler, offset, reconnect, filter, deserializer, allowExistTopic, userName, password, false, backupSites, resubscribeInterval, subOnce);
249249
HandlerLopper handlerLopper = new HandlerLopper(queue, handler, batchSize, throttle == 0 ? -1 : throttle);
250250
handlerLopper.start();
251251
String topicStr = host + ":" + port + "/" + tableName + "/" + actionName;

0 commit comments

Comments
 (0)