Repository: helix Updated Branches: refs/heads/helix-0.6.x 7038c78eb -> fab5423f1
Minor fix on the asynchronous group callbacks. Project: http://git-wip-us.apache.org/repos/asf/helix/repo Commit: http://git-wip-us.apache.org/repos/asf/helix/commit/fab5423f Tree: http://git-wip-us.apache.org/repos/asf/helix/tree/fab5423f Diff: http://git-wip-us.apache.org/repos/asf/helix/diff/fab5423f Branch: refs/heads/helix-0.6.x Commit: fab5423f10a682362de308f1a837d57bf96ebb15 Parents: 7038c78 Author: Lei Xia <[email protected]> Authored: Thu Mar 30 16:12:07 2017 -0700 Committer: Lei Xia <[email protected]> Committed: Thu Mar 30 16:12:07 2017 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/helix/manager/zk/CallbackHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/helix/blob/fab5423f/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java ---------------------------------------------------------------------- diff --git a/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java b/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java index 90df56d..380f299 100644 --- a/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java +++ b/helix-core/src/main/java/org/apache/helix/manager/zk/CallbackHandler.java @@ -170,7 +170,7 @@ public class CallbackHandler implements IZkChildListener, IZkDataListener public void enqueueTask(NotificationContext changeContext) throws Exception { //async mode only applicable to CALLBACK from ZK, During INIT and FINALIZE invoke the callback's immediately. - if (asyncBatchModeEnabled && changeContext.getType() != NotificationContext.Type.CALLBACK) { + if (asyncBatchModeEnabled && changeContext.getType() == NotificationContext.Type.CALLBACK) { logger.info("Enqueuing callback"); _queue.put(changeContext); } else {
