Skip to content

Commit 0d1e6f2

Browse files
committed
IGNITE-24334 Fixed flaky ClientSessionOutboundQueueLimitTest.
1 parent fa69646 commit 0d1e6f2

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

modules/control-utility/src/test/java/org/apache/ignite/events/BaselineEventsTest.java

+3-4
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,6 @@ private IgniteConfiguration getConfiguration(String igniteInstanceName, boolean
7979
return cfg;
8080
}
8181

82-
8382
/** */
8483
protected abstract void listen(IgniteEx ignite, IgnitePredicate<Event> lsnr, int... types);
8584

@@ -89,12 +88,12 @@ public void testInMemoryBaselineAutoAdjustNotProduceEvents() throws Exception {
8988
startGrid(getConfiguration(getTestIgniteInstanceName(0), false));
9089
startGrid(getConfiguration(getTestIgniteInstanceName(1), false));
9190

92-
AtomicBoolean isBaselineChangedEventListened = new AtomicBoolean();
91+
AtomicBoolean isBaselineChangedEvtListened = new AtomicBoolean();
9392

9493
listen(
9594
grid(0),
9695
event -> {
97-
isBaselineChangedEventListened.set(true);
96+
isBaselineChangedEvtListened.set(true);
9897

9998
return true;
10099
},
@@ -103,7 +102,7 @@ public void testInMemoryBaselineAutoAdjustNotProduceEvents() throws Exception {
103102

104103
startGrid(getConfiguration(getTestIgniteInstanceName(2), false));
105104

106-
assertFalse(GridTestUtils.waitForCondition(isBaselineChangedEventListened::get, 2000));
105+
assertFalse(GridTestUtils.waitForCondition(isBaselineChangedEvtListened::get, 2000));
107106
}
108107

109108
/** */

0 commit comments

Comments
 (0)