Mirror/MarginaliaSearch
1
0
Fork 0
mirror of https://github.com/MarginaliaSearch/MarginaliaSearch.git synced 2025-02-23 13:09:00 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

(registry) Fix broken test

Browse Source
This commit is contained in:
Viktor Lofgren 2024-05-23 14:15:01 +02:00
parent 59ec70eb73
commit 65b74f9cab
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
code/common/service/test/nu/marginalia/service/discovery/ZkServiceRegistryTest.java
View File

@ -105,17 +105,17 @@ class ZkServiceRegistryTest {
registry1.announceInstance(uuid1); registry1.announceInstance(uuid1);
registry2.announceInstance(uuid2); registry2.announceInstance(uuid2);
assertEquals(Set.of(endpoint1.asInstance(uuid1)), assertEquals(List.of(endpoint1.asInstance(uuid1)),
registry1.getEndpoints(key1)); registry1.getEndpoints(key1));
assertEquals(Set.of(endpoint2.asInstance(uuid2)), assertEquals(List.of(endpoint2.asInstance(uuid2)),
registry1.getEndpoints(key2)); registry1.getEndpoints(key2));
registry1.shutDown(); registry1.shutDown();
Thread.sleep(100); Thread.sleep(100);
assertEquals(Set.of(), registry2.getEndpoints(key1)); assertEquals(List.of(), registry2.getEndpoints(key1));
assertEquals(Set.of(endpoint2.asInstance(uuid2)), registry2.getEndpoints(key2)); assertEquals(List.of(endpoint2.asInstance(uuid2)), registry2.getEndpoints(key2));
} }
@Test @Test
@ -136,12 +136,12 @@ class ZkServiceRegistryTest {
assertEquals(Set.of(endpoint1.asInstance(uuid1), assertEquals(Set.of(endpoint1.asInstance(uuid1),
endpoint2.asInstance(uuid2)), endpoint2.asInstance(uuid2)),
registry1.getEndpoints(key)); new HashSet<>(registry1.getEndpoints(key)));
registry1.shutDown(); registry1.shutDown();
Thread.sleep(100); Thread.sleep(100);
assertEquals(Set.of(endpoint2.asInstance(uuid2)), registry2.getEndpoints(key)); assertEquals(List.of(endpoint2.asInstance(uuid2)), registry2.getEndpoints(key));
} }
@Test @Test
@ -161,8 +161,8 @@ class ZkServiceRegistryTest {
registry1.announceInstance(uuid1); registry1.announceInstance(uuid1);
registry2.announceInstance(uuid2); registry2.announceInstance(uuid2);
assertEquals(Set.of(endpoint1.asInstance(uuid1)), registry1.getEndpoints(key1)); assertEquals(List.of(endpoint1.asInstance(uuid1)), registry1.getEndpoints(key1));
assertEquals(Set.of(endpoint2.asInstance(uuid2)), registry1.getEndpoints(key2)); assertEquals(List.of(endpoint2.asInstance(uuid2)), registry1.getEndpoints(key2));
} }
@Test @Test