|
57 | 57 | import org.mockito.ArgumentCaptor; |
58 | 58 | import org.mockito.Mockito; |
59 | 59 |
|
| 60 | +import java.util.Arrays; |
60 | 61 | import java.util.HashMap; |
61 | 62 | import java.util.List; |
62 | 63 | import java.util.Map; |
|
69 | 70 | import static org.hamcrest.CoreMatchers.not; |
70 | 71 | import static org.hamcrest.CoreMatchers.nullValue; |
71 | 72 | import static org.hamcrest.MatcherAssert.assertThat; |
| 73 | +import static org.hamcrest.Matchers.containsInAnyOrder; |
72 | 74 | import static org.hamcrest.Matchers.hasSize; |
73 | 75 | import static org.junit.jupiter.api.Assertions.assertNull; |
74 | 76 | import static org.mockito.ArgumentMatchers.any; |
@@ -183,7 +185,9 @@ public void testCreateOrUpdateCreatesCluster(VertxTestContext context) { |
183 | 185 | List<KafkaBridge> capturedStatuses = bridgeCaptor.getAllValues(); |
184 | 186 | assertThat(capturedStatuses.get(0).getStatus().getUrl(), is("http://foo-bridge-service.test.svc:8080")); |
185 | 187 | assertThat(capturedStatuses.get(0).getStatus().getReplicas(), is(bridge.getReplicas())); |
186 | | - assertThat(capturedStatuses.get(0).getStatus().getLabelSelector(), is(bridge.getSelectorLabels().toSelectorString())); |
| 188 | + List<String> expectedParts = Arrays.asList(bridge.getSelectorLabels().toSelectorString().split(",")); |
| 189 | + List<String> actualParts = Arrays.asList(capturedStatuses.get(0).getStatus().getLabelSelector().split(",")); |
| 190 | + assertThat(actualParts, containsInAnyOrder(expectedParts.toArray(new String[0]))); |
187 | 191 | assertThat(capturedStatuses.get(0).getStatus().getConditions().get(0).getStatus(), is("True")); |
188 | 192 | assertThat(capturedStatuses.get(0).getStatus().getConditions().get(0).getType(), is("Ready")); |
189 | 193 |
|
|
0 commit comments