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 8D466189A7 for ; Fri, 19 Feb 2016 18:36:51 +0000 (UTC) Received: (qmail 20659 invoked by uid 500); 19 Feb 2016 18:36:51 -0000 Delivered-To: apmail-geode-commits-archive@geode.apache.org Received: (qmail 20624 invoked by uid 500); 19 Feb 2016 18:36:51 -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 20612 invoked by uid 99); 19 Feb 2016 18:36:51 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Feb 2016 18:36:51 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id E5708C191F for ; Fri, 19 Feb 2016 18:36:50 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -4.026 X-Spam-Level: X-Spam-Status: No, score=-4.026 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.006] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id dti-g8dwsV6g for ; Fri, 19 Feb 2016 18:36:46 +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 519C95FB55 for ; Fri, 19 Feb 2016 18:36:40 +0000 (UTC) Received: (qmail 19572 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 55577E0092; 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:55 -0000 Message-Id: <53c2180b1d374f199fbfd4b1a5e83476@git.apache.org> In-Reply-To: <6b97abc8452d42b888de3a2f139a1c3f@git.apache.org> References: <6b97abc8452d42b888de3a2f139a1c3f@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [18/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/PDXNewWanDUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java index d359e52..a7e17b6 100644 --- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java +++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/PDXNewWanDUnitTest.java @@ -46,31 +46,29 @@ public class PDXNewWanDUnitTest extends WANTestBase{ * 7> Validate whether other sites member receive this put operation. */ public void testWANPDX_RR_SerialSender() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm3.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 1 )); } /** @@ -87,48 +85,46 @@ public class PDXNewWanDUnitTest extends WANTestBase{ * and can deserialize entries. */ public void testWANPDX_RemoveRomoteData() { - 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_PDX", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort )); - vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm3.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 1 )); //bounce vm2 - vm2.invoke(WANTestBase.class, "closeCache"); + vm2.invoke(() -> WANTestBase.closeCache()); - vm2.invoke(WANTestBase.class, "deletePDXDir"); + vm2.invoke(() -> WANTestBase.deletePDXDir()); - vm2.invoke(WANTestBase.class, "createReceiver_PDX", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 2 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 2 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 2 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 2 )); } /** @@ -145,34 +141,32 @@ public class PDXNewWanDUnitTest extends WANTestBase{ * 10> Make sure we flag a warning about the conflicting updates. */ public void testWANPDX_ConflictingData() { - 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_PDX", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort )); - vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm3.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 1 )); //bounce vm3 - vm3.invoke(WANTestBase.class, "closeCache"); + vm3.invoke(() -> WANTestBase.closeCache()); IgnoredException ex1 = IgnoredException.addIgnoredException("Trying to add a PDXType with the same id"); IgnoredException ex2 = IgnoredException.addIgnoredException("CacheWriterException"); @@ -182,29 +176,29 @@ public class PDXNewWanDUnitTest extends WANTestBase{ try { //blow away vm3's PDX data - vm3.invoke(WANTestBase.class, "deletePDXDir"); + vm3.invoke(() -> WANTestBase.deletePDXDir()); - vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm3.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); //Define a different type from vm3 - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable2", new Object[] { getTestMethodName() + "_RR", - 2 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable2( getTestMethodName() + "_RR", + 2 )); //Give the updates some time to make it over the WAN Wait.pause(10000); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 1 )); - vm3.invoke(WANTestBase.class, "closeCache"); + vm3.invoke(() -> WANTestBase.closeCache()); } finally { ex1.remove(); ex2.remove(); @@ -226,108 +220,103 @@ public class PDXNewWanDUnitTest extends WANTestBase{ * 7> Validate whether other sites member receive this put operation. */ public void testWANPDX_RR_SerialSender3Sites() { - 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 )); - Integer tkPort = (Integer)vm2.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 3, lnPort }); + Integer tkPort = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnPort )); - vm3.invoke(WANTestBase.class, "createReceiver", new Object[] { lnPort }); - vm4.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); - vm5.invoke(WANTestBase.class, "createReceiver", new Object[] { tkPort }); + vm3.invoke(() -> WANTestBase.createReceiver( lnPort )); + vm4.invoke(() -> WANTestBase.createReceiver( nyPort )); + vm5.invoke(() -> WANTestBase.createReceiver( tkPort )); //Create all of our gateway senders - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ny", 2, - false, 100, 10, false, false, null, true }); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "tk", 3, - false, 100, 10, false, false, null, true }); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 1, - false, 100, 10, false, false, null, true }); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "tk", 3, - false, 100, 10, false, false, null, true }); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 1, - false, 100, 10, false, false, null, true }); - vm5.invoke(WANTestBase.class, "createSender", new Object[] { "ny", 2, - false, 100, 10, false, false, null, true }); - vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ny,tk", isOffHeap() }); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln,tk", isOffHeap() }); - vm5.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln,ny", isOffHeap() }); + vm3.invoke(() -> WANTestBase.createSender( "ny", 2, + false, 100, 10, false, false, null, true )); + vm3.invoke(() -> WANTestBase.createSender( "tk", 3, + false, 100, 10, false, false, null, true )); + vm4.invoke(() -> WANTestBase.createSender( "ln", 1, + false, 100, 10, false, false, null, true )); + vm4.invoke(() -> WANTestBase.createSender( "tk", 3, + false, 100, 10, false, false, null, true )); + vm5.invoke(() -> WANTestBase.createSender( "ln", 1, + false, 100, 10, false, false, null, true )); + vm5.invoke(() -> WANTestBase.createSender( "ny", 2, + false, 100, 10, false, false, null, true )); + vm3.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ny,tk", isOffHeap() )); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln,tk", isOffHeap() )); + vm5.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln,ny", isOffHeap() )); //Start all of the senders - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ny" }); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "tk" }); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "tk" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm5.invoke(WANTestBase.class, "startSender", new Object[] { "ny" }); + vm3.invoke(() -> WANTestBase.startSender( "ny" )); + vm3.invoke(() -> WANTestBase.startSender( "tk" )); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); + vm4.invoke(() -> WANTestBase.startSender( "tk" )); + vm5.invoke(() -> WANTestBase.startSender( "ln" )); + vm5.invoke(() -> WANTestBase.startSender( "ny" )); //Pause ln to ny. This means the PDX type will not be dispatched //to ny from ln - vm3.invoke(WANTestBase.class, "pauseSender", new Object[] { "ny" }); + vm3.invoke(() -> WANTestBase.pauseSender( "ny" )); Wait.pause(5000); //Do some puts that define a PDX type in ln - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 1 )); //Make sure that tk received the update - vm5.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 1 }); + vm5.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 1 )); //Make ny didn't receive the update because the sender is paused - vm4.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 0 }); + vm4.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 0 )); //Now, do a put from tk. This serialized object will be distributed //to ny from tk, using the type defined by ln. - vm5.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 2 }); + vm5.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 2 )); //Verify the ny can read the object - vm4.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 2 }); + vm4.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 2 )); //Wait for vm3 to receive the update (prevents a broken pipe suspect string) - vm3.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 2 }); + vm3.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 2 )); } public void testWANPDX_RR_SerialSender_StartedLater() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm3.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 10 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 10 )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 40 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 40 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 40 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 40 )); } /** @@ -342,62 +331,58 @@ public class PDXNewWanDUnitTest extends WANTestBase{ */ public void testWANPDX_PR_SerialSender() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 1 )); } public void testWANPDX_PR_SerialSender_StartedLater() { - 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_PDX", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort )); - vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 20 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 20 )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 40 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 40 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 40 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 40 )); } /** @@ -412,68 +397,64 @@ public class PDXNewWanDUnitTest extends WANTestBase{ */ public void testWANPDX_PR_MultipleVM_SerialSender() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); + vm4.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null,1, 5, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null,1, 5, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() }); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() )); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 10 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 10 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 10 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 10 )); } public void testWANPDX_PR_MultipleVM_SerialSender_StartedLater() { - 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_PDX", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort )); - vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); - vm4.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort )); + vm4.invoke(() -> WANTestBase.createCache_PDX( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 5, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 5, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() }); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() )); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 1, 5, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 10 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 10 )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 40 }); + vm4.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 40 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 40 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 40 )); } /** @@ -488,159 +469,148 @@ public class PDXNewWanDUnitTest extends WANTestBase{ */ public void testWANPDX_PR_ParallelSender() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 1, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 1, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 1}); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 1)); } public void testWANPDX_PR_ParallelSender_47826() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, true, - 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, true, + 100, 10, false, false, null, true )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 1, isOffHeap() )); - vm3.invoke(WANTestBase.class, "unsetRemoveFromQueueOnException", - new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.unsetRemoveFromQueueOnException( "ln" )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { - getTestMethodName() + "_PR", 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( + getTestMethodName() + "_PR", 1 )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 1, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 1, isOffHeap() )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 1 )); } public void testWANPDX_PR_ParallelSender_StartedLater() { - 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_PDX", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort )); - vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 10 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 10 )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 40 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 40 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 40 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 40 )); } public void testWANPDX_PR_MultipleVM_ParallelSender() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); + vm4.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 10 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 10 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 10 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 10 )); } public void testWANPDX_PR_MultipleVM_ParallelSender_StartedLater() { - 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_PDX", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver_PDX( nyPort )); - vm3.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); - vm4.invoke(WANTestBase.class, "createCache_PDX", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache_PDX( lnPort )); + vm4.invoke(() -> WANTestBase.createCache_PDX( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 10 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 10 )); - AsyncInvocation inv1 = vm3.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); - AsyncInvocation inv2 = vm4.invokeAsync(WANTestBase.class, "startSender", new Object[] { "ln" }); + AsyncInvocation inv1 = vm3.invokeAsync(() -> WANTestBase.startSender( "ln" )); + AsyncInvocation inv2 = vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); try{ inv1.join(); @@ -650,80 +620,76 @@ public class PDXNewWanDUnitTest extends WANTestBase{ fail("Caught interrupted exception"); } - vm4.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 40 }); + vm4.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 40 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 40 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 40 )); } public void testWANPDX_RR_SerialSenderWithFilter() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, new PDXGatewayEventFilter(), true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, new PDXGatewayEventFilter(), true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm3.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_RR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_RR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_RR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_RR", 1 )); - vm3.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new Object[] { 1}); + vm3.invoke(() -> PDXNewWanDUnitTest.verifyFilterInvocation( 1)); } public void testWANPDX_PR_MultipleVM_ParallelSenderWithFilter() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); + vm4.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, new PDXGatewayEventFilter(), true }); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - true, 100, 10, false, false, new PDXGatewayEventFilter(), true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, new PDXGatewayEventFilter(), true )); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + true, 100, 10, false, false, new PDXGatewayEventFilter(), true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 10 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 10 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 10 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 10 )); - vm3.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new Object[] { 5}); - vm4.invoke(PDXNewWanDUnitTest.class, "verifyFilterInvocation", new Object[] { 5}); + vm3.invoke(() -> PDXNewWanDUnitTest.verifyFilterInvocation( 5)); + vm4.invoke(() -> PDXNewWanDUnitTest.verifyFilterInvocation( 5)); } @@ -732,47 +698,45 @@ public class PDXNewWanDUnitTest extends WANTestBase{ */ public void Bug_testWANPDX_PR_SerialSender_RemoteSite_Bounce() { - 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.createReceiver( nyPort )); - vm3.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm3.invoke(() -> WANTestBase.createCache( lnPort )); - vm3.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm3.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 0, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm3.invoke(() -> WANTestBase.startSender( "ln" )); - vm3.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() }); + vm3.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", "ln", 0, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 1 )); - vm2.invoke(WANTestBase.class, "killSender", new Object[] {}); + vm2.invoke(() -> WANTestBase.killSender()); - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); - vm4.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); + vm4.invoke(() -> WANTestBase.createReceiver( nyPort )); - vm2.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 2, isOffHeap() }); - vm4.invoke(WANTestBase.class, "createPartitionedRegion", new Object[] { - getTestMethodName() + "_PR", null, 1, 2, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 2, isOffHeap() )); + vm4.invoke(() -> WANTestBase.createPartitionedRegion( + getTestMethodName() + "_PR", null, 1, 2, isOffHeap() )); - vm3.invoke(WANTestBase.class, "doPutsPDXSerializable", new Object[] { getTestMethodName() + "_PR", - 1 }); + vm3.invoke(() -> WANTestBase.doPutsPDXSerializable( getTestMethodName() + "_PR", + 1 )); - vm2.invoke(WANTestBase.class, "validateRegionSize_PDX", new Object[] { - getTestMethodName() + "_PR", 1 }); + vm2.invoke(() -> WANTestBase.validateRegionSize_PDX( + getTestMethodName() + "_PR", 1 )); }