Showing
1 changed file
with
1 additions
and
1 deletions
@@ -103,7 +103,7 @@ public class BaseEdgeEventControllerTest extends AbstractControllerTest { | @@ -103,7 +103,7 @@ public class BaseEdgeEventControllerTest extends AbstractControllerTest { | ||
103 | new TypeReference<PageData<EdgeEvent>>() {}, new TimePageLink(4)).getData(); | 103 | new TypeReference<PageData<EdgeEvent>>() {}, new TimePageLink(4)).getData(); |
104 | attempt++; | 104 | attempt++; |
105 | Thread.sleep(100); | 105 | Thread.sleep(100); |
106 | - } while (edgeEvents.size() != 4 || attempt < 5); | 106 | + } while (edgeEvents.size() != 4 && attempt < 5); |
107 | Assert.assertEquals(4, edgeEvents.size()); | 107 | Assert.assertEquals(4, edgeEvents.size()); |
108 | Assert.assertTrue(edgeEvents.stream().anyMatch(ee -> EdgeEventType.RULE_CHAIN.equals(ee.getType()))); | 108 | Assert.assertTrue(edgeEvents.stream().anyMatch(ee -> EdgeEventType.RULE_CHAIN.equals(ee.getType()))); |
109 | Assert.assertTrue(edgeEvents.stream().anyMatch(ee -> EdgeEventType.DEVICE.equals(ee.getType()))); | 109 | Assert.assertTrue(edgeEvents.stream().anyMatch(ee -> EdgeEventType.DEVICE.equals(ee.getType()))); |