mhansonp commented on code in PR #7608: URL: https://github.com/apache/geode/pull/7608#discussion_r854670769
########## geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/DurableClientBug39997DUnitTest.java: ########## @@ -50,81 +46,63 @@ public class DurableClientBug39997DUnitTest extends JUnit4CacheTestCase { @Override public final void postTearDownCacheTestCase() { - Host.getHost(0).getVM(0).invoke(JUnit4DistributedTestCase::disconnectFromDS); + VM.getVM(0).invoke(JUnit4DistributedTestCase::disconnectFromDS); } @Test public void testNoServerAvailableOnStartup() { Host host = Host.getHost(0); - VM vm0 = host.getVM(0); - VM vm1 = host.getVM(1); + VM vm0 = VM.getVM(0); + VM vm1 = VM.getVM(1); - final String hostName = NetworkUtils.getServerHostName(host); + final String hostName = VM.getHostName(); final int port = AvailablePortHelper.getRandomAvailableTCPPort(); - vm0.invoke(new SerializableRunnable("create cache") { - @Override - public void run() { - getSystem(getClientProperties()); - PoolImpl p = (PoolImpl) PoolManager.createFactory().addServer(hostName, port) - .setSubscriptionEnabled(true).setSubscriptionRedundancy(0) - .create("DurableClientReconnectDUnitTestPool"); - AttributesFactory factory = new AttributesFactory(); - factory.setScope(Scope.LOCAL); - factory.setPoolName(p.getName()); - Cache cache = getCache(); - Region region1 = cache.createRegion("region", factory.create()); - cache.readyForEvents(); + vm0.invoke("create cache", () -> { + getSystem(getClientProperties()); + PoolImpl p = (PoolImpl) PoolManager.createFactory().addServer(hostName, port) + .setSubscriptionEnabled(true).setSubscriptionRedundancy(0) + .create("DurableClientReconnectDUnitTestPool"); + Cache cache = getCache(); + RegionFactory regionFactory = cache.createRegionFactory(); + regionFactory.setScope(Scope.LOCAL); + regionFactory.setPoolName(p.getName()); + Region region1 = regionFactory.create("region"); - try { - region1.registerInterest("ALL_KEYS"); - fail("Should have received an exception trying to register interest"); - } catch (NoSubscriptionServersAvailableException expected) { - // this is expected - } + try { + region1.registerInterestForAllKeys(); + fail("Should have received an exception trying to register interest"); + } catch (NoSubscriptionServersAvailableException expected) { + // this is expected } + cache.readyForEvents(); Review Comment: Fixed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: notifications-unsubscr...@geode.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org