Return-Path: X-Original-To: apmail-geode-commits-archive@minotaur.apache.org Delivered-To: apmail-geode-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E57A0189EA for ; Fri, 19 Feb 2016 18:37:24 +0000 (UTC) Received: (qmail 30529 invoked by uid 500); 19 Feb 2016 18:37:24 -0000 Delivered-To: apmail-geode-commits-archive@geode.apache.org Received: (qmail 30482 invoked by uid 500); 19 Feb 2016 18:37:24 -0000 Mailing-List: contact commits-help@geode.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@geode.incubator.apache.org Delivered-To: mailing list commits@geode.incubator.apache.org Received: (qmail 30386 invoked by uid 99); 19 Feb 2016 18:37:24 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Feb 2016 18:37:24 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 2ACECC0CC3 for ; Fri, 19 Feb 2016 18:37:24 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.349 X-Spam-Level: X-Spam-Status: No, score=-4.349 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.329] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id yv6MKj1b8nmd for ; Fri, 19 Feb 2016 18:36:51 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with SMTP id 364B25FB52 for ; Fri, 19 Feb 2016 18:36:40 +0000 (UTC) Received: (qmail 19565 invoked by uid 99); 19 Feb 2016 18:36:39 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Feb 2016 18:36:39 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 43210E0231; Fri, 19 Feb 2016 18:36:39 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: upthewaterspout@apache.org To: commits@geode.incubator.apache.org Date: Fri, 19 Feb 2016 18:36:51 -0000 Message-Id: <2b95a30297114ea1b0b9e9e1d6d241e4@git.apache.org> In-Reply-To: <6b97abc8452d42b888de3a2f139a1c3f@git.apache.org> References: <6b97abc8452d42b888de3a2f139a1c3f@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [14/63] [abbrv] incubator-geode git commit: Automatically converting calls of vm.invoke to lambdas http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java index 80514d9..2fef83a 100644 --- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java +++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanValidationsDUnitTest.java @@ -59,31 +59,23 @@ public class WanValidationsDUnitTest extends WANTestBase { throws Exception { IgnoredException.addIgnoredException("another cache has the same region defined"); try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, "createFirstLocatorWithDSId", - new Object[] {1}); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, "createFirstRemoteLocator", - new Object[] {2, lnPort}); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1)); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(2, lnPort)); - vm4.invoke(WANTestBase.class, "createCache", - new Object[] {lnPort }); - vm5.invoke(WANTestBase.class, "createCache", - new Object[] {lnPort }); - - vm4.invoke(WANTestBase.class, "createSender", - new Object[] {"ln1", 2, false, 10, 100, false, false, null, true}); - vm4.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2", 2, false, 10, 100, false, false, null, true}); + vm4.invoke(() -> WANTestBase.createCache(lnPort )); + vm5.invoke(() -> WANTestBase.createCache(lnPort )); + + vm4.invoke(() -> WANTestBase.createSender("ln1", 2, false, 10, 100, false, false, null, true)); + vm4.invoke(() -> WANTestBase.createSender("ln2", 2, false, 10, 100, false, false, null, true)); - vm5.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2", 2, false, 10, 100, false, false, null, true}); - vm5.invoke(WANTestBase.class, "createSender", - new Object[] {"ln3", 2, false, 10, 100, false, false, null, true}); + vm5.invoke(() -> WANTestBase.createSender("ln2", 2, false, 10, 100, false, false, null, true)); + vm5.invoke(() -> WANTestBase.createSender("ln3", 2, false, 10, 100, false, false, null, true)); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() }); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln1,ln2", isOffHeap() )); - vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln2,ln3", isOffHeap() }); + vm5.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln2,ln3", isOffHeap() )); fail("Expected IllegalStateException with incompatible gateway sender ids message"); } catch (Exception e) { @@ -111,25 +103,23 @@ public class WanValidationsDUnitTest extends WANTestBase { public void DISABLED_DUETO_BUG51491_testParallelGatewaySenderForDistributedRegion() throws Exception { try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln1", 2, - true, 10, 100, false, false, null, false }); + vm4.invoke(() -> WANTestBase.createSender( "ln1", 2, + true, 10, 100, false, false, null, false )); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln2", 2, - true, 10, 100, false, false, null, false }); + vm5.invoke(() -> WANTestBase.createSender( "ln2", 2, + true, 10, 100, false, false, null, false )); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln1", isOffHeap() }); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln1", isOffHeap() )); - vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln1", isOffHeap() }); + vm5.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln1", isOffHeap() )); } catch (Exception e) { @@ -145,28 +135,21 @@ public class WanValidationsDUnitTest extends WANTestBase { throws Exception { IgnoredException.addIgnoredException("another cache has the same region defined"); try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, "createFirstLocatorWithDSId", - new Object[] {1}); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1)); - vm4.invoke(WANTestBase.class, "createCache", - new Object[] {lnPort }); - vm5.invoke(WANTestBase.class, "createCache", - new Object[] {lnPort }); + vm4.invoke(() -> WANTestBase.createCache(lnPort )); + vm5.invoke(() -> WANTestBase.createCache(lnPort )); - vm4.invoke(WANTestBase.class, "createSender", - new Object[] {"ln1", 2, false, 10, 100, false, false, null, true}); - vm4.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2", 2, false, 10, 100, false, false, null, true}); + vm4.invoke(() -> WANTestBase.createSender("ln1", 2, false, 10, 100, false, false, null, true)); + vm4.invoke(() -> WANTestBase.createSender("ln2", 2, false, 10, 100, false, false, null, true)); - vm5.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2", 2, false, 10, 100, false, false, null, true}); - vm5.invoke(WANTestBase.class, "createSender", - new Object[] {"ln3", 2, false, 10, 100, false, false, null, true}); + vm5.invoke(() -> WANTestBase.createSender("ln2", 2, false, 10, 100, false, false, null, true)); + vm5.invoke(() -> WANTestBase.createSender("ln3", 2, false, 10, 100, false, false, null, true)); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln1,ln2", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln2,ln3", 1, 100, isOffHeap() }); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln1,ln2", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln2,ln3", 1, 100, isOffHeap() )); fail("Expected IllegalStateException with incompatible gateway sender ids message"); } catch (Exception e) { @@ -183,18 +166,15 @@ public class WanValidationsDUnitTest extends WANTestBase { public void testReplicatedSerialAsyncEventQueueWithPeristenceEnabled() { IgnoredException.addIgnoredException("another cache has the same region defined"); try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, - "createReplicatedRegionWithAsyncEventQueue", new Object[] { - getTestMethodName() + "_RR", "ln1", isOffHeap() }); - vm5.invoke(WANTestBase.class, - "createReplicatedRegionWithAsyncEventQueue", new Object[] { - getTestMethodName() + "_RR", "ln2", isOffHeap() }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createReplicatedRegionWithAsyncEventQueue( + getTestMethodName() + "_RR", "ln1", isOffHeap() )); + vm5.invoke(() -> WANTestBase.createReplicatedRegionWithAsyncEventQueue( + getTestMethodName() + "_RR", "ln2", isOffHeap() )); fail("Expected IllegalStateException with incompatible gateway sender ids message"); } catch (Exception e) { @@ -215,28 +195,21 @@ public class WanValidationsDUnitTest extends WANTestBase { throws Exception { IgnoredException.addIgnoredException("another cache has the same region defined"); try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, "createFirstLocatorWithDSId", - new Object[] {1}); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1)); - vm4.invoke(WANTestBase.class, "createCache", - new Object[] {lnPort }); - vm5.invoke(WANTestBase.class, "createCache", - new Object[] {lnPort }); + vm4.invoke(() -> WANTestBase.createCache(lnPort )); + vm5.invoke(() -> WANTestBase.createCache(lnPort )); - vm4.invoke(WANTestBase.class, "createSender", - new Object[] {"ln1", 2, true, 10, 100, false, false, null, true}); - vm4.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2", 2, true, 10, 100, false, false, null, true}); + vm4.invoke(() -> WANTestBase.createSender("ln1", 2, true, 10, 100, false, false, null, true)); + vm4.invoke(() -> WANTestBase.createSender("ln2", 2, true, 10, 100, false, false, null, true)); - vm5.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2", 2, true, 10, 100, false, false, null, true}); - vm5.invoke(WANTestBase.class, "createSender", - new Object[] {"ln3", 2, true, 10, 100, false, false, null, true}); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln1,ln2", 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln2,ln3", 1, 100, isOffHeap() }); + vm5.invoke(() -> WANTestBase.createSender("ln2", 2, true, 10, 100, false, false, null, true)); + vm5.invoke(() -> WANTestBase.createSender("ln3", 2, true, 10, 100, false, false, null, true)); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln1,ln2", 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln2,ln3", 1, 100, isOffHeap() )); fail("Expected IllegalStateException with incompatible gateway sender ids message"); } @@ -259,22 +232,17 @@ public class WanValidationsDUnitTest extends WANTestBase { public void ___testSameParallelGatewaySenderIdAcrossDifferentPartitionedRegion() throws Exception { try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln1_Parallel", 2, true, 10, 100, false, false, null, true}); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2_Parallel", 2, true, 10, 100, false, false, null, true}); + vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true)); + vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true)); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR1", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() }); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR2", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() }); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR1", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() )); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR2", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() )); } catch (Exception e) { @@ -290,22 +258,17 @@ public class WanValidationsDUnitTest extends WANTestBase { throws Exception { IgnoredException.addIgnoredException("another cache has the same region defined"); try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln1_Parallel", 2, true, 10, 100, false, false, null, true}); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2_Parallel", 2, true, 10, 100, false, false, null, true}); + vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true)); + vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true)); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR1", null, "ln1_Parallel", null, isOffHeap() }); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR2", null, "ln1_Parallel,ln2_Parallel", getTestMethodName() + "_PR1", isOffHeap() }); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR1", null, "ln1_Parallel", null, isOffHeap() )); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR2", null, "ln1_Parallel,ln2_Parallel", getTestMethodName() + "_PR1", isOffHeap() )); //now we support this //fail("Expected IllegalStateException with incompatible gateway sender ids in colocated regions"); } @@ -329,22 +292,17 @@ public class WanValidationsDUnitTest extends WANTestBase { public void testSameParallelGatewaySenderIdAcrossColocatedPartitionedRegion2() throws Exception { try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln1_Parallel", 2, true, 10, 100, false, false, null, true}); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2_Parallel", 2, true, 10, 100, false, false, null, true}); + vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true)); + vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true)); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR1", null, "ln1_Parallel", null, isOffHeap() }); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR2", null, null, getTestMethodName() + "_PR1", isOffHeap() }); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR1", null, "ln1_Parallel", null, isOffHeap() )); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR2", null, null, getTestMethodName() + "_PR1", isOffHeap() )); } catch (Exception e) { @@ -361,22 +319,19 @@ public class WanValidationsDUnitTest extends WANTestBase { public void testSameParallelGatewaySenderIdAcrossColocatedPartitionedRegion3() throws Exception { try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSender", new Object[] { - "ln1_Parallel", 2, true, 10, 100, false, false, null, true }); - vm1.invoke(WANTestBase.class, "createSender", new Object[] { - "ln2_Parallel", 2, true, 10, 100, false, false, null, true }); + vm1.invoke(() -> WANTestBase.createSender( + "ln1_Parallel", 2, true, 10, 100, false, false, null, true )); + vm1.invoke(() -> WANTestBase.createSender( + "ln2_Parallel", 2, true, 10, 100, false, false, null, true )); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR1", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() }); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR2", null, "ln1_Parallel", getTestMethodName() + "_PR1", isOffHeap() }); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR1", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() )); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR2", null, "ln1_Parallel", getTestMethodName() + "_PR1", isOffHeap() )); } catch (Exception e) { Assert.fail("The tests caught Exception.", e); @@ -392,24 +347,18 @@ public class WanValidationsDUnitTest extends WANTestBase { public void testSameParallelGatewaySenderIdAcrossColocatedPartitionedRegion4() throws Exception { try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln1_Parallel", 2, true, 10, 100, false, false, null, true}); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln2_Parallel", 2, true, 10, 100, false, false, null, true}); - vm1.invoke(WANTestBase.class, "createSender", - new Object[] {"ln3_Parallel", 2, true, 10, 100, false, false, null, true}); - - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR1", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() }); - vm1.invoke(WANTestBase.class, - "createPartitionedRegionWithSerialParallelSenderIds", new Object[] { - getTestMethodName() + "_PR2", null, "ln1_Parallel,ln2_Parallel,ln3_Parallel", getTestMethodName() + "_PR1", isOffHeap() }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + + vm1.invoke(() -> WANTestBase.createSender("ln1_Parallel", 2, true, 10, 100, false, false, null, true)); + vm1.invoke(() -> WANTestBase.createSender("ln2_Parallel", 2, true, 10, 100, false, false, null, true)); + vm1.invoke(() -> WANTestBase.createSender("ln3_Parallel", 2, true, 10, 100, false, false, null, true)); + + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR1", null, "ln1_Parallel,ln2_Parallel", null, isOffHeap() )); + vm1.invoke(() -> WANTestBase.createPartitionedRegionWithSerialParallelSenderIds( + getTestMethodName() + "_PR2", null, "ln1_Parallel,ln2_Parallel,ln3_Parallel", getTestMethodName() + "_PR1", isOffHeap() )); //now we support this //fail("Expected IllegalStateException with incompatible gateway sender ids in colocated regions"); } catch (Exception e) { @@ -427,16 +376,15 @@ public class WanValidationsDUnitTest extends WANTestBase { * SerialGatewaySender and ParallelGatewaySender with same name is allowed */ public void testSerialGatewaySenderAndParallelGatewaySenderWithSameName() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { - "ln", 2, false, 100, false, false, null, null, true, false }); + vm1.invoke(() -> WANTestBase.createSenderForValidations( + "ln", 2, false, 100, false, false, null, null, true, false )); try { - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { - "ln", 2, true, 100, false, false, null, null, true, false }); + vm1.invoke(() -> WANTestBase.createSenderForValidations( + "ln", 2, true, 100, false, false, null, null, true, false )); fail("Expected IllegateStateException : Sender names should be different."); } catch (Exception e) { if (!(e.getCause() instanceof IllegalStateException) @@ -449,20 +397,19 @@ public class WanValidationsDUnitTest extends WANTestBase { //remote ds ids should be same public void testSameRemoteDSAcrossSameSender() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, null, null, - true, false }); + true, false )); try { - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 3, false, 100, false, false, null, null, - true, false }); + true, false )); fail("Expected IllegateStateException : Remote Ds Ids should match"); } catch (Exception e) { @@ -476,19 +423,18 @@ public class WanValidationsDUnitTest extends WANTestBase { // sender with same name should be either serial or parallel but not both. public void testSerialSenderOnBothCache() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, null, null, - true, false }); + true, false )); try { - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { - "ln", 2, true, 100, false, false, null, null, true, false }); + vm2.invoke(() -> WANTestBase.createSenderForValidations( + "ln", 2, true, 100, false, false, null, null, true, false )); fail("Expected IllegateStateException : is not serial Gateway Sender"); } catch (Exception e) { @@ -502,21 +448,20 @@ public class WanValidationsDUnitTest extends WANTestBase { // sender with same name should be either serial or parallel but not both. public void testParallelSenderOnBothCache(){ - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, "createFirstLocatorWithDSId", - new Object[] {1}); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1)); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, true, 100,false, false, - null, null, true, false }); + null, null, true, false )); try { vm2 - .invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, + .invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false,null, null, - true, false }); + true, false )); fail("Expected IllegateStateException : is not parallel Gateway Sender"); } catch (Exception e) { @@ -529,21 +474,20 @@ public class WanValidationsDUnitTest extends WANTestBase { // isBatchConflation should be same across the same sender public void testBatchConflation() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - null, null, true, false }); + null, null, true, false )); // isBatchConflation try { - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100,true, false, - null, null, true, false }); + null, null, true, false )); fail("Expected IllegateStateException : isBatchConflation Should match"); } catch (Exception e) { @@ -556,18 +500,17 @@ public class WanValidationsDUnitTest extends WANTestBase { //isPersistentEnabled should be same across the same sender public void testisPersistentEnabled() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - null, null, true, false }); + null, null, true, false )); try { - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, - false, 100,false, true, null, null, true, false }); + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, + false, 100,false, true, null, null, true, false )); fail("Expected IllegateStateException : isPersistentEnabled Should match"); } catch (Exception e) { @@ -579,18 +522,17 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testAlertThreshold() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - null, null, true, false }); + null, null, true, false )); try { - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, - false, 50, false, false, null, null, true, false }); + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, + false, 50, false, false, null, null, true, false )); fail("Expected IllegateStateException : alertThreshold Should match"); } catch (Exception e) { @@ -602,18 +544,17 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testManualStart() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - null, null, true, false }); + null, null, true, false )); try { - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { "ln", 2, - false, 100, false, false, null, null, false, false }); + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, + false, 100, false, false, null, null, false, false )); fail("Expected IllegateStateException : manualStart Should match"); } catch (Exception e) { @@ -625,23 +566,22 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testGatewayEventFilters() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); ArrayList eventFiletrs = new ArrayList(); eventFiletrs.add(new MyGatewayEventFilter()); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, eventFiletrs, - null, true, false }); + null, true, false )); try { eventFiletrs = new ArrayList(); eventFiletrs.add(new Filter70()); - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - eventFiletrs, null, true, false }); + eventFiletrs, null, true, false )); fail("Expected IllegateStateException : GatewayEventFileters Should match"); } catch (Exception e) { @@ -654,24 +594,23 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testGatewayEventFilters2() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); ArrayList eventFiletrs = new ArrayList(); eventFiletrs.add(new MyGatewayEventFilter()); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, eventFiletrs, - null, true, false }); + null, true, false )); try { eventFiletrs = new ArrayList(); eventFiletrs.add(new MyGatewayEventFilter()); eventFiletrs.add(new Filter70()); - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - eventFiletrs, null, true, false }); + eventFiletrs, null, true, false )); fail("Expected IllegateStateException : GatewayEventFileters Should match"); } catch (Exception e) { @@ -684,25 +623,24 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testGatewayTransportFilters() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); ArrayList transportFiletrs = new ArrayList(); transportFiletrs.add(new MyGatewayTransportFilter1()); transportFiletrs.add(new MyGatewayTransportFilter2()); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, null, - transportFiletrs, true, false }); + transportFiletrs, true, false )); try { transportFiletrs = new ArrayList(); transportFiletrs.add(new MyGatewayTransportFilter3()); transportFiletrs.add(new MyGatewayTransportFilter4()); - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - null, transportFiletrs, true, false }); + null, transportFiletrs, true, false )); fail("Expected IllegateStateException : GatewayEventFileters Should match"); } catch (Exception e) { @@ -715,25 +653,24 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testGatewayTransportFiltersOrder() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); ArrayList transportFiletrs = new ArrayList(); transportFiletrs.add(new MyGatewayTransportFilter1()); transportFiletrs.add(new MyGatewayTransportFilter2()); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, null, - transportFiletrs, true, false }); + transportFiletrs, true, false )); try { transportFiletrs = new ArrayList(); transportFiletrs.add(new MyGatewayTransportFilter2()); transportFiletrs.add(new MyGatewayTransportFilter1()); - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, - null, transportFiletrs, true, false }); + null, transportFiletrs, true, false )); fail("Expected IllegateStateException : GatewayEventFileters Should match"); } catch (Exception e) { @@ -749,17 +686,17 @@ public class WanValidationsDUnitTest extends WANTestBase { // Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, // "createFirstLocatorWithDSId", new Object[] { 1 }); // -// vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); -// vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); +// vm1.invoke(() -> WANTestBase.createCache( lnPort )); +// vm2.invoke(() -> WANTestBase.createCache( lnPort )); // -// vm1.invoke(WANTestBase.class, "createSenderWithListener", new Object[] { +// vm1.invoke(() -> WANTestBase.createSenderWithListener( // "ln", 2, false, 100, 10, false, false, null, -// true, true }); +// true, true )); // // try { -// vm2.invoke(WANTestBase.class, "createSenderWithListener", new Object[] { +// vm2.invoke(() -> WANTestBase.createSenderWithListener( // "ln", 2, false, 100, 10, false, false, null, -// false, true }); +// false, true )); // fail("Expected IllegateStateException : GatewayEventFileters Should match"); // } // catch (Exception e) { @@ -772,20 +709,19 @@ public class WanValidationsDUnitTest extends WANTestBase { // } public void testIsDiskSynchronous() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm1.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, null, - null, true, false }); + null, true, false )); try { - vm2.invoke(WANTestBase.class, "createSenderForValidations", new Object[] { + vm2.invoke(() -> WANTestBase.createSenderForValidations( "ln", 2, false, 100, false, false, null, - null, true, true }); + null, true, true )); fail("Expected IllegateStateException : isDiskSynchronous Should match"); } catch (Exception e) { @@ -803,14 +739,13 @@ public class WanValidationsDUnitTest extends WANTestBase { * Expected: Cache.getCacheServer should return only the Bridge server and not the Receiver */ public void test_GetCacheServersDoesNotReturnReceivers() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm4.invoke(WANTestBase.class, "createReceiver", new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createReceiver( lnPort )); - vm4.invoke(WANTestBase.class, "createCacheServer", new Object[] { }); + vm4.invoke(() -> WANTestBase.createCacheServer( )); - Map cacheServers = (Map) vm4.invoke(WANTestBase.class, "getCacheServers", new Object[] { }); + Map cacheServers = (Map) vm4.invoke(() -> WANTestBase.getCacheServers( )); assertEquals("Cache.getCacheServers returned incorrect BridgeServers: ", 1, cacheServers.get("BridgeServer")); assertEquals("Cache.getCacheServers returned incorrect ReceiverServers: ", 0, cacheServers.get("ReceiverServer")); @@ -823,16 +758,15 @@ public class WanValidationsDUnitTest extends WANTestBase { * Expected: Cache.getCacheServers should only return the bridge server and not the Receiver. */ public void test_GetCacheServersDoesNotReturnReceivers_Scenario2() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm4.invoke(WANTestBase.class, "createReceiver", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createReceiver( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); - vm5.invoke(WANTestBase.class, "createCacheServer", new Object[] { }); + vm5.invoke(() -> WANTestBase.createCacheServer( )); - Map cacheServers_vm4 = (Map) vm4.invoke(WANTestBase.class, "getCacheServers", new Object[] { }); - Map cacheServers_vm5 = (Map) vm5.invoke(WANTestBase.class, "getCacheServers", new Object[] { }); + Map cacheServers_vm4 = (Map) vm4.invoke(() -> WANTestBase.getCacheServers( )); + Map cacheServers_vm5 = (Map) vm5.invoke(() -> WANTestBase.getCacheServers( )); assertEquals("Cache.getCacheServers on vm4 returned incorrect BridgeServers: ", 0, cacheServers_vm4.get("BridgeServer")); assertEquals("Cache.getCacheServers on vm4 returned incorrect ReceiverServers: ", 0, cacheServers_vm4.get("ReceiverServer")); @@ -849,19 +783,18 @@ public class WanValidationsDUnitTest extends WANTestBase { * on number of machines */ public void DISABLED_testDispatcherThreadsForParallelGatewaySender() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); + vm1.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); // dispatcher threads try { - vm2.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY }); + vm2.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 4, OrderPolicy.KEY )); fail("Expected IllegateStateException : dispatcher threads Should match"); } catch (Exception e) { @@ -880,19 +813,18 @@ public class WanValidationsDUnitTest extends WANTestBase { * disabling the tests */ public void DISABLED_testOrderPolicyForParallelGatewaySender() { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - vm1.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm2.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm1.invoke(() -> WANTestBase.createCache( lnPort )); + vm2.invoke(() -> WANTestBase.createCache( lnPort )); - vm1.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY }); + vm1.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.KEY )); // dispatcher threads try { - vm2.invoke(WANTestBase.class, "createConcurrentSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true, 5, OrderPolicy.PARTITION }); + vm2.invoke(() -> WANTestBase.createConcurrentSender( "ln", 2, + true, 100, 10, false, false, null, true, 5, OrderPolicy.PARTITION )); fail("Expected IllegateStateException : order policy Should match"); } catch (Exception e) { @@ -904,43 +836,41 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testBug50434_RR_Serial() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_RR", "ln"}); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_RR", "ln")); - vm5.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_RR", "ln"}); + vm5.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_RR", "ln")); try { - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", - 10 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", + 10 )); fail("Expected GatewaySenderConfigurationException : Sender Ids should match"); } catch (Exception e) { @@ -953,41 +883,38 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testBug50434_RR_SerialAsyncEventQueue() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm5.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm6.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm7.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_RR", "ln" }); - - vm5.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_RR", "ln" }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm5.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm6.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm7.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" )); + + vm5.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" )); try { - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", - 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", + 1000 )); fail("Expected GatewaySenderConfigurationException : AsyncEvent queue IDs should match"); } catch (Exception e) { @@ -1000,153 +927,144 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testBug50434_RR_Serial_Pass() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_RR", "ln"}); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_RR", "ln")); - vm5.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_RR", "ln"}); + vm5.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_RR", "ln")); - vm6.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_RR", "ln"}); + vm6.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_RR", "ln")); - vm7.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_RR", "ln"}); + vm7.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_RR", "ln")); - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", - 10}); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", + 10)); - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName() + "_RR", 10}); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName() + "_RR", 10)); } public void testBug50434_RR_SerialAsyncEventQueue_Pass() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm5.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm6.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm7.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_RR", "ln" }); - vm5.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_RR", "ln" }); - vm6.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_RR", "ln" }); - vm7.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_RR", "ln" }); - - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", - 1000 }); - - vm4.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 1000 });// primary sender - vm5.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 0 });// secondary - vm6.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 0 });// secondary - vm7.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 0 });// secondary + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm5.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm6.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm7.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" )); + vm5.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" )); + vm6.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" )); + vm7.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_RR", "ln" )); + + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", + 1000 )); + + vm4.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 1000 ));// primary sender + vm5.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 0 ));// secondary + vm6.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 0 ));// secondary + vm7.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 0 ));// secondary } public void testBug50434_PR_Serial() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); - - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_RR", null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); - vm6.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); - vm7.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); + + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_RR", null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); + vm5.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); + vm6.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); + vm7.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); - vm5.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); + vm5.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); try { - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", - 10}); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", + 10)); fail("Expected GatewaySenderConfigurationException : Sender Ids should match"); } catch (Exception e) { @@ -1159,40 +1077,37 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testBug50434_PR_SerialAsyncEventQueue() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm5.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm6.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm7.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_PR", "ln" }); - vm5.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_PR", "ln" }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm5.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm6.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm7.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_PR", "ln" )); + vm5.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_PR", "ln" )); try { - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", - 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", + 1000 )); fail("Expected GatewaySenderConfigurationException : AsyncEvent queue IDs should match"); } catch (Exception e) { @@ -1205,154 +1120,145 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testBug50434_PR_Serial_Pass() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); - - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); - vm6.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); - vm7.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); + + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); + vm5.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); + vm6.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); + vm7.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm6.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm7.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm6.invoke(() -> WANTestBase.startSender( "ln" )); + vm7.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); - vm5.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); - vm6.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); - vm7.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); + vm5.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); + vm6.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); + vm7.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", - 10}); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", + 10)); - vm4.invoke(WANTestBase.class, "validateQueueContents", new Object[] { "ln", - 0}); + vm4.invoke(() -> WANTestBase.validateQueueContents( "ln", + 0)); - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName() + "_PR", 10}); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName() + "_PR", 10)); } public void testBug50434_PR_SerialAsyncEventQueue_Pass() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm5.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm6.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - vm7.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - false, 100, 100, false, false, null, false }); - - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 100, isOffHeap() }); - - vm4.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_PR", "ln" }); - vm5.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_PR", "ln" }); - vm6.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_PR", "ln" }); - vm7.invoke(WANTestBase.class, "addAsyncEventQueueThroughAttributesMutator", - new Object[] { getTestMethodName() + "_PR", "ln" }); - - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", - 1000 }); - - vm4.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 1000 });// primary sender - vm5.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 0 });// secondary - vm6.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 0 });// secondary - vm7.invoke(WANTestBase.class, "validateAsyncEventListener", new Object[] { - "ln", 0 });// secondary + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm5.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm6.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + vm7.invoke(() -> WANTestBase.createAsyncEventQueue( "ln", + false, 100, 100, false, false, null, false )); + + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 100, isOffHeap() )); + + vm4.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_PR", "ln" )); + vm5.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_PR", "ln" )); + vm6.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_PR", "ln" )); + vm7.invoke(() -> WANTestBase.addAsyncEventQueueThroughAttributesMutator( getTestMethodName() + "_PR", "ln" )); + + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", + 1000 )); + + vm4.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 1000 ));// primary sender + vm5.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 0 ));// secondary + vm6.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 0 ));// secondary + vm7.invoke(() -> WANTestBase.validateAsyncEventListener( + "ln", 0 ));// secondary } public void testBug50434_PR_Parallel() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); - - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 10, isOffHeap()}); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); + + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 10, isOffHeap())); + + vm4.invoke(() -> WANTestBase.createCache( lnPort )); + vm5.invoke(() -> WANTestBase.createCache( lnPort )); + vm6.invoke(() -> WANTestBase.createCache( lnPort )); + vm7.invoke(() -> WANTestBase.createCache( lnPort )); + + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); + vm5.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 10, isOffHeap()}); - vm5.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 10, isOffHeap()}); - vm6.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 10, isOffHeap()}); - vm7.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 10, isOffHeap()}); - - vm4.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); - vm5.invoke(WANTestBase.class, "addSenderThroughAttributesMutator", new Object[] { - getTestMethodName() + "_PR", "ln"}); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 10, isOffHeap())); + vm5.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 10, isOffHeap())); + vm6.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 10, isOffHeap())); + vm7.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 10, isOffHeap())); + + vm4.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); + vm5.invoke(() -> WANTestBase.addSenderThroughAttributesMutator( + getTestMethodName() + "_PR", "ln")); - vm4.invoke(WANTestBase.class, "waitForSenderRunningState", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.waitForSenderRunningState( "ln" )); try { - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_PR", - 10}); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", + 10)); fail("Expected GatewaySenderConfigurationException : Sender Ids should match"); } catch (Exception e) { @@ -1365,40 +1271,37 @@ public class WanValidationsDUnitTest extends WANTestBase { } public void testBug50434_PR_ParallelAsyncEventQueue() throws Exception { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm5.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm6.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm7.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - - vm4.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - true, 100, 100, false, false, null, false }); - vm5.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - true, 100, 100, false, false, null, false }); - vm6.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - true, 100, 100, false, false, null, false }); - vm7.invoke(WANTestBase.class, "createAsyncEventQueue", new Object[] { "ln", - true, 100, 100, false, false, null, false }); - - vm4.in