Skip to content

Commit b150150

Browse files
committed
Harden ProxyRestartIT
(merge ce/main -> ce/24.09 12273) [git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v24.09/": change = 112274]
1 parent 878b91c commit b150150

File tree

1 file changed

+0
-15
lines changed

1 file changed

+0
-15
lines changed

prj/test/functional/grpc-client-tck/src/main/java/grpc/client/ProxyRestartIT.java

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -163,21 +163,6 @@ void shouldCleanUpProxiesOnServiceStop()
163163
cFilter = (Integer) mbeanServer.getAttribute(sMBean, "ListenerFilterCount");
164164
assertThat(cKey, is(0));
165165
assertThat(cFilter, is(0));
166-
167-
// do a get on the gRPC cache to reconnect, we do this in an assertDeferred because it may take a second
168-
// or so for the gRPC server to be fully up and registered with the name service
169-
Eventually.assertDeferred(() -> cache.get("key-1"), is("value-1"));
170-
171-
// listeners should have been re-registered
172-
cKey = (Integer) mbeanServer.getAttribute(sMBean, "ListenerKeyCount");
173-
cFilter = (Integer) mbeanServer.getAttribute(sMBean, "ListenerFilterCount");
174-
assertThat(cKey, is(1));
175-
assertThat(cFilter, is(1));
176-
177-
// do an update and check we get the events
178-
cache.put("key-1", "value-1.1");
179-
Eventually.assertDeferred(listener1::getUpdateCount, is(1));
180-
Eventually.assertDeferred(listener2::getUpdateCount, is(1));
181166
}
182167

183168
// ----- helper methods -------------------------------------------------

0 commit comments

Comments
 (0)