Skip to content

Commit

Permalink
0003731: Gaps taking longer to expire and using slower method of
Browse files Browse the repository at this point in the history
querying sym_data
  • Loading branch information
erilong committed Sep 20, 2018
1 parent c9cf79a commit 284db66
Showing 1 changed file with 2 additions and 2 deletions.
Expand Up @@ -502,9 +502,9 @@ protected int routeDataForEachChannel() {
if (nodeChannel.isEnabled() && (readyChannels == null || readyChannels.contains(nodeChannel.getChannelId()))) {
processInfo.setCurrentChannelId(nodeChannel.getChannelId());
dataCount += routeDataForChannel(processInfo, nodeChannel, sourceNode);
} else {
} else if (!nodeChannel.isEnabled()) {
gapDetector.setIsAllDataRead(false);
if (log.isDebugEnabled() && !nodeChannel.isEnabled()) {
if (log.isDebugEnabled()) {
log.debug("Not routing the {} channel. It is either disabled or suspended.", nodeChannel.getChannelId());
}
}
Expand Down

0 comments on commit 284db66

Please sign in to comment.