# IGNITE-709 Fix GridEventConsumeSelfTest.testMasterNodeLeave
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4b790a8f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4b790a8f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4b790a8f Branch: refs/heads/ignite-929 Commit: 4b790a8fdd109daf67b38fcd5b032951b2b785e6 Parents: 97533b3 Author: sevdokimov <sergey.evdoki...@jetbrains.com> Authored: Sun May 24 22:51:24 2015 +0300 Committer: sevdokimov <sergey.evdoki...@jetbrains.com> Committed: Sun May 24 22:51:24 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/continuous/GridEventConsumeSelfTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4b790a8f/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java index f41aaa0..223c082 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java @@ -860,7 +860,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { final CountDownLatch latch = new CountDownLatch(GRID_CNT); for (int i = 0; i < GRID_CNT; i++) { - grid(0).events().localListen(new IgnitePredicate<Event>() { + grid(i).events().localListen(new IgnitePredicate<Event>() { @Override public boolean apply(Event evt) { if (nodeId.equals(((DiscoveryEvent) evt).eventNode().id())) latch.countDown();
