You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ji...@apache.org on 2016/04/14 16:57:06 UTC
[1/4] incubator-geode git commit: GEODE-17: refactor
CliCommandTestBase to use Parameterized Junit runs to do all combinations of
http/non-http and security/non-security runs
Repository: incubator-geode
Updated Branches:
refs/heads/feature/GEODE-17-2 9734aa80d -> e08fd9fd9
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandPauseResumeDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandPauseResumeDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandPauseResumeDUnitTest.java
index b54b27f..500e7ef 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandPauseResumeDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandPauseResumeDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.DistributedMember;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result;
@@ -33,16 +23,29 @@ import com.gemstone.gemfire.management.internal.cli.i18n.CliStrings;
import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.pause;
@Category(DistributedTest.class)
public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
+ public WanCommandPauseResumeDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Test
public void testPauseGatewaySender_ErrorConditions() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -50,13 +53,13 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
String command = CliStrings.PAUSE_GATEWAYSENDER + " --"
+ CliStrings.PAUSE_GATEWAYSENDER__ID + "=ln --"
@@ -81,7 +84,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
@Test
public void testPauseGatewaySender_onMember() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -89,18 +92,18 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.PAUSE_GATEWAYSENDER + " --"
+ CliStrings.PAUSE_GATEWAYSENDER__ID + "=ln --"
@@ -116,14 +119,14 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testPauseGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
}
@Test
public void testPauseGatewaySender() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -131,27 +134,27 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
pause(10000);
@@ -174,11 +177,11 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testPauseGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, true ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, true ));
}
@@ -189,7 +192,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
@Test
public void testPauseGatewaySender_Group() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -197,30 +200,30 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
pause(10000);
@@ -245,11 +248,11 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testPauseGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, true ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, true ));
}
@@ -260,7 +263,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
@Test
public void testPauseGatewaySender_MultipleGroup() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -268,44 +271,44 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1, SenderGroup2" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm6.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm6.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup2" ));
- vm6.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm6.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm7.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm7.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup3" ));
- vm7.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm7.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
+ vm6.invoke(() -> startSender( "ln" ));
+ vm7.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", true, false ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", true, false ));
pause(10000);
@@ -329,22 +332,22 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testPauseGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, true ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, true ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", true, true ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", true, false ));
}
@Test
public void testResumeGatewaySender_ErrorConditions() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -352,13 +355,13 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
String command = CliStrings.RESUME_GATEWAYSENDER + " --"
+ CliStrings.RESUME_GATEWAYSENDER__ID + "=ln --"
@@ -380,7 +383,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
@Test
public void testResumeGatewaySender() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -388,38 +391,38 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
- vm3.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
+ vm3.invoke(() -> pauseSender( "ln" ));
+ vm4.invoke(() -> pauseSender( "ln" ));
+ vm5.invoke(() -> pauseSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, true ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, true ));
pause(10000);
@@ -442,11 +445,11 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testResumeGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -457,7 +460,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
@Test
public void testResumeGatewaySender_onMember() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -465,23 +468,23 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm3.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
+ vm3.invoke(() -> pauseSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.RESUME_GATEWAYSENDER + " --"
+ CliStrings.RESUME_GATEWAYSENDER__ID + "=ln --"
@@ -497,7 +500,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testResumeGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -508,7 +511,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
@Test
public void testResumeGatewaySender_Group() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -516,41 +519,41 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
- vm3.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
+ vm3.invoke(() -> pauseSender( "ln" ));
+ vm4.invoke(() -> pauseSender( "ln" ));
+ vm5.invoke(() -> pauseSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, true ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, true ));
pause(10000);
@@ -574,11 +577,11 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testResumeGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -589,7 +592,7 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
@Test
public void testResumeGatewaySender_MultipleGroup() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -597,61 +600,61 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1, SenderGroup2" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm6.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm6.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup2" ));
- vm6.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm6.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm7.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm7.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup3" ));
- vm7.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm7.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
+ vm6.invoke(() -> startSender( "ln" ));
+ vm7.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", true, false ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", true, false ));
- vm3.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm6.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
- vm7.invoke(() -> WANCommandTestBase.pauseSender( "ln" ));
+ vm3.invoke(() -> pauseSender( "ln" ));
+ vm4.invoke(() -> pauseSender( "ln" ));
+ vm5.invoke(() -> pauseSender( "ln" ));
+ vm6.invoke(() -> pauseSender( "ln" ));
+ vm7.invoke(() -> pauseSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, true ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, true ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, true ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", true, true ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", true, true ));
pause(10000);
@@ -675,15 +678,15 @@ public class WanCommandPauseResumeDUnitTest extends WANCommandTestBase {
fail("testResumeGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", true, false ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", true, true ));
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
index 7293963..d2e295e 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.DistributedMember;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result;
@@ -34,42 +24,55 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.result.CompositeResultData;
import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.pause;
@Category(DistributedTest.class)
public class WanCommandStatusDUnitTest extends WANCommandTestBase{
private static final long serialVersionUID = 1L;
+ public WanCommandStatusDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Test
public void testGatewaySenderStatus(){
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm6.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( lnPort ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createCache( lnPort ));
+ vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm4.invoke(() -> WANCommandTestBase.createCache( lnPort ));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createCache( lnPort ));
+ vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm5.invoke(() -> WANCommandTestBase.createCache( lnPort ));
- vm5.invoke(() -> WANCommandTestBase.createSender(
+ vm5.invoke(() -> createCache( lnPort ));
+ vm5.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true));
- vm5.invoke(() -> WANCommandTestBase.createSender(
+ vm5.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
pause(10000);
@@ -96,14 +99,14 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
fail("testListGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln_Serial" ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln_Parallel" ));
+ vm3.invoke(() -> startSender( "ln_Serial" ));
+ vm3.invoke(() -> startSender( "ln_Parallel" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln_Serial" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln_Parallel" ));
+ vm4.invoke(() -> startSender( "ln_Serial" ));
+ vm4.invoke(() -> startSender( "ln_Parallel" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln_Serial" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln_Parallel" ));
+ vm5.invoke(() -> startSender( "ln_Serial" ));
+ vm5.invoke(() -> startSender( "ln_Parallel" ));
pause(10000);
command = CliStrings.STATUS_GATEWAYSENDER + " --"
@@ -133,32 +136,32 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
@Test
public void testGatewaySenderStatus_OnMember(){
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm6.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( lnPort ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createCache( lnPort ));
+ vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm4.invoke(() -> WANCommandTestBase.createCache( lnPort ));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createCache( lnPort ));
+ vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm5.invoke(() -> WANCommandTestBase.createCache( lnPort ));
+ vm5.invoke(() -> createCache( lnPort ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.STATUS_GATEWAYSENDER + " --"
@@ -181,11 +184,11 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
fail("testListGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln_Serial" ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln_Parallel" ));
+ vm3.invoke(() -> startSender( "ln_Serial" ));
+ vm3.invoke(() -> startSender( "ln_Parallel" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln_Serial" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln_Parallel" ));
+ vm4.invoke(() -> startSender( "ln_Serial" ));
+ vm4.invoke(() -> startSender( "ln_Parallel" ));
pause(10000);
command = CliStrings.STATUS_GATEWAYSENDER + " --"
@@ -212,7 +215,7 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
fail("testListGatewaySender failed as did not get CommandResult");
}
- final DistributedMember vm5Member = (DistributedMember) vm5.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm5Member = (DistributedMember) vm5.invoke(() -> getMember());
command = CliStrings.STATUS_GATEWAYSENDER + " --"
+ CliStrings.STATUS_GATEWAYSENDER__ID + "=ln_Serial --"
@@ -234,38 +237,38 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
@Test
public void testGatewaySenderStatus_OnGroups(){
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm7.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm7.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups( lnPort, "Serial_Sender, Paralle_Sender"));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createCacheWithGroups( lnPort, "Serial_Sender, Paralle_Sender"));
+ vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups( lnPort,"Serial_Sender, Paralle_Sender"));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createCacheWithGroups( lnPort,"Serial_Sender, Paralle_Sender"));
+ vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups( lnPort,"Paralle_Sender"));
- vm5.invoke(() -> WANCommandTestBase.createSender(
+ vm5.invoke(() -> createCacheWithGroups( lnPort,"Paralle_Sender"));
+ vm5.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true));
- vm5.invoke(() -> WANCommandTestBase.createSender(
+ vm5.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm6.invoke(() -> WANCommandTestBase.createCacheWithGroups( lnPort,"Serial_Sender"));
+ vm6.invoke(() -> createCacheWithGroups( lnPort,"Serial_Sender"));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.STATUS_GATEWAYSENDER + " --"
@@ -293,11 +296,11 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
fail("testListGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln_Serial" ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln_Parallel" ));
+ vm3.invoke(() -> startSender( "ln_Serial" ));
+ vm3.invoke(() -> startSender( "ln_Parallel" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln_Serial" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln_Parallel" ));
+ vm4.invoke(() -> startSender( "ln_Serial" ));
+ vm4.invoke(() -> startSender( "ln_Parallel" ));
pause(10000);
command = CliStrings.STATUS_GATEWAYSENDER + " --"
@@ -328,20 +331,20 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
@Test
public void testGatewayReceiverStatus(){
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm6.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
+ vm3.invoke(() -> createAndStartReceiver( lnPort ));
+ vm4.invoke(() -> createAndStartReceiver( lnPort ));
+ vm5.invoke(() -> createAndStartReceiver( lnPort ));
pause(10000);
String command = CliStrings.STATUS_GATEWAYRECEIVER;
@@ -370,9 +373,9 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
fail("testGatewayReceiverStatus failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.stopReceiver());
- vm4.invoke(() -> WANCommandTestBase.stopReceiver());
- vm5.invoke(() -> WANCommandTestBase.stopReceiver());
+ vm3.invoke(() -> stopReceiver());
+ vm4.invoke(() -> stopReceiver());
+ vm5.invoke(() -> stopReceiver());
pause(10000);
@@ -405,22 +408,22 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
@Test
public void testGatewayReceiverStatus_OnMember(){
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm6.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
+ vm3.invoke(() -> createAndStartReceiver( lnPort ));
+ vm4.invoke(() -> createAndStartReceiver( lnPort ));
+ vm5.invoke(() -> createAndStartReceiver( lnPort ));
- final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.STATUS_GATEWAYRECEIVER+ " --"
@@ -445,9 +448,9 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
fail("testGatewayReceiverStatus failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.stopReceiver());
- vm4.invoke(() -> WANCommandTestBase.stopReceiver());
- vm5.invoke(() -> WANCommandTestBase.stopReceiver());
+ vm3.invoke(() -> stopReceiver());
+ vm4.invoke(() -> stopReceiver());
+ vm5.invoke(() -> stopReceiver());
pause(10000);
@@ -479,21 +482,21 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
@Test
public void testGatewayReceiverStatus_OnGroups(){
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm7.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm7.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( lnPort, "RG1, RG2" ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( lnPort, "RG1, RG2" ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( lnPort, "RG1" ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( lnPort, "RG2" ));
+ vm3.invoke(() -> createAndStartReceiverWithGroup( lnPort, "RG1, RG2" ));
+ vm4.invoke(() -> createAndStartReceiverWithGroup( lnPort, "RG1, RG2" ));
+ vm5.invoke(() -> createAndStartReceiverWithGroup( lnPort, "RG1" ));
+ vm6.invoke(() -> createAndStartReceiverWithGroup( lnPort, "RG2" ));
pause(10000);
String command = CliStrings.STATUS_GATEWAYRECEIVER + " --"
@@ -518,9 +521,9 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
fail("testGatewayReceiverStatus failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.stopReceiver());
- vm4.invoke(() -> WANCommandTestBase.stopReceiver());
- vm5.invoke(() -> WANCommandTestBase.stopReceiver());
+ vm3.invoke(() -> stopReceiver());
+ vm4.invoke(() -> stopReceiver());
+ vm5.invoke(() -> stopReceiver());
pause(10000);
command = CliStrings.STATUS_GATEWAYRECEIVER + " --"+ CliStrings.STATUS_GATEWAYRECEIVER__GROUP + "=RG1";
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
index 4ff9a73..f67f22a 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
@@ -16,27 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.configuration;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-import java.util.Collection;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Properties;
-import java.util.Set;
-
-import org.apache.commons.io.FileUtils;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.LogWriter;
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheFactory;
@@ -80,6 +59,26 @@ import com.gemstone.gemfire.test.dunit.SerializableCallable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.apache.commons.io.FileUtils;
+import org.junit.Ignore;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Properties;
+import java.util.Set;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
@Category(DistributedTest.class)
public class ClusterConfigurationDUnitTest extends CliCommandTestBase {
@@ -107,6 +106,10 @@ public class ClusterConfigurationDUnitTest extends CliCommandTestBase {
private static final long serialVersionUID = 1L;
+ public ClusterConfigurationDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Test
public void testConfigDistribution() throws IOException {
IgnoredException.addIgnoredException("could not get remote locator");
[2/4] incubator-geode git commit: GEODE-17: refactor
CliCommandTestBase to use Parameterized Junit runs to do all combinations of
http/non-http and security/non-security runs
Posted by ji...@apache.org.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java
index 5edd3d2..a0d907c 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStartDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.DistributedMember;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result;
@@ -35,12 +25,25 @@ import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.pause;
@Category(DistributedTest.class)
public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
+ public WanCommandGatewayReceiverStartDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
/**
* Test wan commands for error in input 1> start gateway-sender command needs
* only one of member or group.
@@ -49,18 +52,18 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
public void testStartGatewayReceiver_ErrorConditions() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
+ vm3.invoke(() -> createReceiver( punePort ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
String command = CliStrings.START_GATEWAYRECEIVER + " --"
+ CliStrings.START_GATEWAYRECEIVER__MEMBER + "=" + vm1Member.getId() + " --"
@@ -82,22 +85,22 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
public void testStartGatewayReceiver() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
+ vm3.invoke(() -> createReceiver( punePort ));
+ vm4.invoke(() -> createReceiver( punePort ));
+ vm5.invoke(() -> createReceiver( punePort ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
pause(10000);
String command = CliStrings.START_GATEWAYRECEIVER;
@@ -115,9 +118,9 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
fail("testStartGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( true ));
+ vm5.invoke(() -> verifyReceiverState( true ));
}
/**
@@ -128,24 +131,24 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
public void testStartGatewayReceiver_onMember() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
+ vm3.invoke(() -> createReceiver( punePort ));
+ vm4.invoke(() -> createReceiver( punePort ));
+ vm5.invoke(() -> createReceiver( punePort ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.START_GATEWAYRECEIVER + " --"
+ CliStrings.START_GATEWAYRECEIVER__MEMBER+ "=" + vm1Member.getId();
@@ -161,9 +164,9 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
fail("testStartGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
}
/**
@@ -174,22 +177,22 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
public void testStartGatewayReceiver_Group() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG1" ));
- vm4.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG1" ));
- vm5.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG1" ));
+ vm3.invoke(() -> createReceiverWithGroup( punePort, "RG1" ));
+ vm4.invoke(() -> createReceiverWithGroup( punePort, "RG1" ));
+ vm5.invoke(() -> createReceiverWithGroup( punePort, "RG1" ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
pause(10000);
String command = CliStrings.START_GATEWAYRECEIVER + " --"
@@ -211,9 +214,9 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
fail("testStartGatewayReceiver_Group failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( true ));
+ vm5.invoke(() -> verifyReceiverState( true ));
}
/**
@@ -225,26 +228,26 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
public void testStartGatewayReceiver_MultipleGroup() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG1" ));
- vm4.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG1" ));
- vm5.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG1, RG2" ));
- vm6.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG1, RG2" ));
- vm7.invoke(() -> WANCommandTestBase.createReceiverWithGroup( punePort, "RG3" ));
+ vm3.invoke(() -> createReceiverWithGroup( punePort, "RG1" ));
+ vm4.invoke(() -> createReceiverWithGroup( punePort, "RG1" ));
+ vm5.invoke(() -> createReceiverWithGroup( punePort, "RG1, RG2" ));
+ vm6.invoke(() -> createReceiverWithGroup( punePort, "RG1, RG2" ));
+ vm7.invoke(() -> createReceiverWithGroup( punePort, "RG3" ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm6.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm7.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
+ vm6.invoke(() -> verifyReceiverState( false ));
+ vm7.invoke(() -> verifyReceiverState( false ));
pause(10000);
String command = CliStrings.START_GATEWAYRECEIVER + " --"
@@ -266,11 +269,11 @@ public class WanCommandGatewayReceiverStartDUnitTest extends WANCommandTestBase
fail("testStartGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm6.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm7.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( true));
+ vm5.invoke(() -> verifyReceiverState( true ));
+ vm6.invoke(() -> verifyReceiverState( true ));
+ vm7.invoke(() -> verifyReceiverState( false ));
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java
index d7bb6c3..b4fa91b 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewayReceiverStopDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.DistributedMember;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result;
@@ -35,12 +25,25 @@ import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.pause;
@Category(DistributedTest.class)
public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
+ public WanCommandGatewayReceiverStopDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
/**
* Test wan commands for error in input 1> start gateway-sender command needs
* only one of member or group.
@@ -49,18 +52,18 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
public void testStopGatewayReceiver_ErrorConditions() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createReceiver( punePort ));
+ vm3.invoke(() -> createReceiver( punePort ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
String command = CliStrings.STOP_GATEWAYRECEIVER + " --"
+ CliStrings.STOP_GATEWAYRECEIVER__MEMBER + "=" + vm1Member.getId()
@@ -83,22 +86,22 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
public void testStopGatewayReceiver() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiver( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiver( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiver( punePort ));
+ vm3.invoke(() -> createAndStartReceiver( punePort ));
+ vm4.invoke(() -> createAndStartReceiver( punePort ));
+ vm5.invoke(() -> createAndStartReceiver( punePort ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( true ));
+ vm5.invoke(() -> verifyReceiverState( true ));
pause(10000);
String command = CliStrings.STOP_GATEWAYRECEIVER;
@@ -118,9 +121,9 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
}
/**
@@ -131,24 +134,24 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
public void testStopGatewayReceiver_onMember() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiver( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiver( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiver( punePort ));
+ vm3.invoke(() -> createAndStartReceiver( punePort ));
+ vm4.invoke(() -> createAndStartReceiver( punePort ));
+ vm5.invoke(() -> createAndStartReceiver( punePort ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( true ));
+ vm5.invoke(() -> verifyReceiverState( true ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.STOP_GATEWAYRECEIVER + " --"
+ CliStrings.STOP_GATEWAYRECEIVER__MEMBER + "=" + vm1Member.getId();
@@ -165,9 +168,9 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( true ));
+ vm5.invoke(() -> verifyReceiverState( true ));
}
/**
@@ -178,22 +181,22 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
public void testStopGatewayReceiver_Group() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG1" ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG1" ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG1" ));
+ vm3.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG1" ));
+ vm4.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG1" ));
+ vm5.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG1" ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( true ));
+ vm5.invoke(() -> verifyReceiverState( true ));
pause(10000);
String command = CliStrings.STOP_GATEWAYRECEIVER + " --"
@@ -216,9 +219,9 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewayReceiver_Group failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
}
/**
@@ -230,26 +233,26 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
public void testStopGatewayReceiver_MultipleGroup() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer) puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer) puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG1" ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG1" ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG1" ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG1, RG2" ));
- vm7.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( punePort, "RG3" ));
+ vm3.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG1" ));
+ vm4.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG1" ));
+ vm5.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG1" ));
+ vm6.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG1, RG2" ));
+ vm7.invoke(() -> createAndStartReceiverWithGroup( punePort, "RG3" ));
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm6.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
- vm7.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( true ));
+ vm4.invoke(() -> verifyReceiverState( true ));
+ vm5.invoke(() -> verifyReceiverState( true ));
+ vm6.invoke(() -> verifyReceiverState( true ));
+ vm7.invoke(() -> verifyReceiverState( true ));
pause(10000);
String command = CliStrings.STOP_GATEWAYRECEIVER + " --"
@@ -272,10 +275,10 @@ public class WanCommandGatewayReceiverStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm6.invoke(() -> WANCommandTestBase.verifyReceiverState( false ));
- vm7.invoke(() -> WANCommandTestBase.verifyReceiverState( true ));
+ vm3.invoke(() -> verifyReceiverState( false ));
+ vm4.invoke(() -> verifyReceiverState( false ));
+ vm5.invoke(() -> verifyReceiverState( false ));
+ vm6.invoke(() -> verifyReceiverState( false ));
+ vm7.invoke(() -> verifyReceiverState( true ));
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStartDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStartDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStartDUnitTest.java
index ecc6cec..5d6aea9 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStartDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStartDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.DistributedMember;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result;
@@ -34,12 +24,25 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.dunit.IgnoredException;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.pause;
@Category(DistributedTest.class)
public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
+ public WanCommandGatewaySenderStartDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
/**
* Test wan commands for error in input 1> start gateway-sender command needs
* only one of member or group.
@@ -47,7 +50,7 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
@Test
public void testStartGatewaySender_ErrorConditions() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -55,13 +58,13 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
String command = CliStrings.START_GATEWAYSENDER + " --"
+ CliStrings.START_GATEWAYSENDER__ID + "=ln --"
@@ -92,7 +95,7 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
@Test
public void testStartGatewaySender() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -100,23 +103,23 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
pause(10000);
@@ -138,11 +141,11 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
fail("testStartGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -153,7 +156,7 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
@Test
public void testStartGatewaySender_onMember() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -161,16 +164,16 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.START_GATEWAYSENDER + " --"
+ CliStrings.START_GATEWAYSENDER__ID + "=ln --"
@@ -186,7 +189,7 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
fail("testStartGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -197,7 +200,7 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
@Test
public void testStartGatewaySender_Group() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -205,26 +208,26 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
pause(10000);
@@ -248,11 +251,11 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
fail("testStartGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -263,7 +266,7 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
@Test
public void testStartGatewaySender_MultipleGroup() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -271,38 +274,38 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1, SenderGroup2" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm6.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm6.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1, SenderGroup2" ));
- vm6.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm6.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm7.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm7.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup3" ));
- vm7.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm7.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", false, false ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", false, false ));
pause(10000);
@@ -325,15 +328,15 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
fail("testStartGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", true, false ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", false, false ));
}
@@ -344,7 +347,7 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
@Test
public void testStartGatewaySender_Group_MissingSenderFromGroup() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -352,22 +355,22 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
pause(10000);
@@ -392,9 +395,9 @@ public class WanCommandGatewaySenderStartDUnitTest extends WANCommandTestBase {
fail("testStartGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStopDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStopDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStopDUnitTest.java
index a90b984..a5787c8 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStopDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandGatewaySenderStopDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.DistributedMember;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result;
@@ -34,12 +24,25 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.dunit.IgnoredException;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.pause;
@Category(DistributedTest.class)
public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
+ public WanCommandGatewaySenderStopDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
private CommandResult executeCommandWithIgnoredExceptions(String command) {
final IgnoredException exln = IgnoredException.addIgnoredException("Could not connect");
CommandResult commandResult = executeCommand(command);
@@ -50,7 +53,7 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
@Test
public void testStopGatewaySender_ErrorConditions() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -58,13 +61,13 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
String command = CliStrings.STOP_GATEWAYSENDER + " --"
+ CliStrings.STOP_GATEWAYSENDER__ID + "=ln --"
@@ -85,7 +88,7 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
@Test
public void testStopGatewaySender() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -93,27 +96,27 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
pause(10000);
@@ -136,11 +139,11 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
}
@@ -151,7 +154,7 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
@Test
public void testStopGatewaySender_onMember() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -159,18 +162,18 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm1Member = (DistributedMember) vm3.invoke(() -> getMember());
pause(10000);
String command = CliStrings.STOP_GATEWAYSENDER + " --"
+ CliStrings.STOP_GATEWAYSENDER__ID + "=ln --"
@@ -186,7 +189,7 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
}
@@ -197,7 +200,7 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
@Test
public void testStopGatewaySender_Group() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -205,30 +208,30 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
pause(10000);
@@ -254,11 +257,11 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
}
@@ -269,7 +272,7 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
@Test
public void testStopGatewaySender_MultipleGroup() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -277,44 +280,44 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm3.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm3.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm3.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm4.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm4.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm5.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup1, SenderGroup2" ));
- vm5.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm5.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm6.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm6.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup2" ));
- vm6.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm6.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm7.invoke(() -> WANCommandTestBase.createCacheWithGroups(
+ vm7.invoke(() -> createCacheWithGroups(
punePort, "SenderGroup3" ));
- vm7.invoke(() -> WANCommandTestBase.createSender( "ln",
+ vm7.invoke(() -> createSender( "ln",
2, false, 100, 400, false, false, null, true ));
- vm3.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm4.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm5.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm6.invoke(() -> WANCommandTestBase.startSender( "ln" ));
- vm7.invoke(() -> WANCommandTestBase.startSender( "ln" ));
+ vm3.invoke(() -> startSender( "ln" ));
+ vm4.invoke(() -> startSender( "ln" ));
+ vm5.invoke(() -> startSender( "ln" ));
+ vm6.invoke(() -> startSender( "ln" ));
+ vm7.invoke(() -> startSender( "ln" ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", true, false ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", true, false ));
pause(10000);
@@ -339,15 +342,15 @@ public class WanCommandGatewaySenderStopDUnitTest extends WANCommandTestBase {
fail("testStopGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
- vm6.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm6.invoke(() -> verifySenderState(
"ln", false, false ));
- vm7.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm7.invoke(() -> verifySenderState(
"ln", true, false ));
}
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
index bcab986..8be2d78 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result;
import com.gemstone.gemfire.management.internal.cli.i18n.CliStrings;
@@ -34,16 +24,29 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.result.CompositeResultData;
import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.pause;
@Category(DistributedTest.class)
public class WanCommandListDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
+ public WanCommandListDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Test
public void testListGatewayWithNoSenderReceiver() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -51,11 +54,11 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
pause(10000);
String command = CliStrings.LIST_GATEWAY;
@@ -72,7 +75,7 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
@Test
public void testListGatewaySender() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -80,25 +83,25 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
- vm7.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm6.invoke(() -> createAndStartReceiver( nyPort ));
+ vm7.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createCache( punePort ));
+ vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createSender(
+ vm5.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
pause(10000);
@@ -125,7 +128,7 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
@Test
public void testListGatewayReceiver() {
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -133,20 +136,20 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm3.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
- vm4.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
+ vm3.invoke(() -> createAndStartReceiver( lnPort ));
+ vm4.invoke(() -> createAndStartReceiver( lnPort ));
vm5
- .invoke(() -> WANCommandTestBase.createCache( nyPort ));
- vm5.invoke(() -> WANCommandTestBase.createSender(
+ .invoke(() -> createCache( nyPort ));
+ vm5.invoke(() -> createSender(
"ln_Serial", 1, false, 100, 400, false, false, null, false ));
vm6
- .invoke(() -> WANCommandTestBase.createCache( nyPort ));
- vm6.invoke(() -> WANCommandTestBase.createSender(
+ .invoke(() -> createCache( nyPort ));
+ vm6.invoke(() -> createSender(
"ln_Serial", 1, false, 100, 400, false, false, null, false ));
- vm6.invoke(() -> WANCommandTestBase.createSender(
+ vm6.invoke(() -> createSender(
"ln_Parallel", 1, true, 100, 400, false, false, null, false ));
pause(10000);
@@ -175,7 +178,7 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
@Test
public void testListGatewaySenderGatewayReceiver() throws GfJsonException {
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -183,28 +186,28 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm6.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( lnPort ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createCache( lnPort ));
+ vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm4.invoke(() -> WANCommandTestBase.createCache( lnPort ));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createCache( lnPort ));
+ vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiver( lnPort ));
+ vm5.invoke(() -> createAndStartReceiver( lnPort ));
- vm7.invoke(() -> WANCommandTestBase.createCache( nyPort ));
- vm7.invoke(() -> WANCommandTestBase.createSender(
+ vm7.invoke(() -> createCache( nyPort ));
+ vm7.invoke(() -> createSender(
"ln_Serial", 1, false, 100, 400, false, false, null, false ));
- vm7.invoke(() -> WANCommandTestBase.createSender(
+ vm7.invoke(() -> createSender(
"ln_Parallel", 1, true, 100, 400, false, false, null, false ));
pause(10000);
@@ -237,7 +240,7 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
@Test
public void testListGatewaySenderGatewayReceiver_group() {
- Integer lnPort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer lnPort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -245,31 +248,31 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + lnPort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, lnPort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, lnPort ));
- vm6.invoke(() -> WANCommandTestBase.createAndStartReceiver( nyPort ));
+ vm6.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups( lnPort, "Serial_Sender, Paralle_Sender"));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createCacheWithGroups( lnPort, "Serial_Sender, Paralle_Sender"));
+ vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
- vm3.invoke(() -> WANCommandTestBase.createSender(
+ vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups( lnPort,"Serial_Sender, Paralle_Sender"));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createCacheWithGroups( lnPort,"Serial_Sender, Paralle_Sender"));
+ vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm4.invoke(() -> WANCommandTestBase.createSender(
+ vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
- vm5.invoke(() -> WANCommandTestBase.createAndStartReceiverWithGroup( lnPort, "Paralle_Sender,Receiver_Group" ));
- vm5.invoke(() -> WANCommandTestBase.createSender(
+ vm5.invoke(() -> createAndStartReceiverWithGroup( lnPort, "Paralle_Sender,Receiver_Group" ));
+ vm5.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm7.invoke(() -> WANCommandTestBase.createCache( nyPort ));
- vm7.invoke(() -> WANCommandTestBase.createSender(
+ vm7.invoke(() -> createCache( nyPort ));
+ vm7.invoke(() -> createSender(
"ln_Serial", 1, false, 100, 400, false, false, null, false ));
- vm7.invoke(() -> WANCommandTestBase.createSender(
+ vm7.invoke(() -> createSender(
"ln_Parallel", 1, true, 100, 400, false, false, null, false ));
pause(10000);
[4/4] incubator-geode git commit: GEODE-17: refactor
CliCommandTestBase to use Parameterized Junit runs to do all combinations of
http/non-http and security/non-security runs
Posted by ji...@apache.org.
GEODE-17: refactor CliCommandTestBase to use Parameterized Junit runs to do all combinations of http/non-http and security/non-security runs
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/e08fd9fd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/e08fd9fd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/e08fd9fd
Branch: refs/heads/feature/GEODE-17-2
Commit: e08fd9fd9040416448f3d4c14f3672b99c976f7f
Parents: 9734aa8
Author: Jinmei Liao <ji...@pivotal.io>
Authored: Thu Apr 14 07:56:17 2016 -0700
Committer: Jinmei Liao <ji...@pivotal.io>
Committed: Thu Apr 14 07:56:17 2016 -0700
----------------------------------------------------------------------
.../LauncherLifecycleCommandsDUnitTest.java | 77 ++--
.../SharedConfigurationEndToEndDUnitTest.java | 14 +-
.../security/ManagementInterceptor.java | 95 +++--
.../cli/commands/CliCommandTestBase.java | 42 ++-
.../cli/commands/CommandOverHttpDunitTest.java | 56 ---
.../CommandOverHttpSecurityDUnitTest.java | 60 ---
.../cli/commands/ConfigCommandsDUnitTest.java | 43 ++-
...eateAlterDestroyRegionCommandsDUnitTest.java | 51 +--
.../cli/commands/DeployCommandsDUnitTest.java | 25 +-
.../commands/DiskStoreCommandsDUnitTest.java | 37 +-
.../commands/DiskStoreCommandsJUnitTest.java | 33 +-
.../cli/commands/FunctionCommandsDUnitTest.java | 31 +-
.../commands/GemfireDataCommandsDUnitTest.java | 51 +--
...WithCacheLoaderDuringCacheMissDUnitTest.java | 28 +-
.../cli/commands/IndexCommandsDUnitTest.java | 21 +-
...stAndDescribeDiskStoreCommandsDUnitTest.java | 23 +-
.../ListAndDescribeRegionDUnitTest.java | 18 +-
.../cli/commands/ListIndexCommandDUnitTest.java | 40 +-
.../MiscellaneousCommandsDUnitTest.java | 41 ++-
...laneousCommandsExportLogsPart1DUnitTest.java | 27 +-
...laneousCommandsExportLogsPart2DUnitTest.java | 28 +-
...laneousCommandsExportLogsPart3DUnitTest.java | 34 +-
...laneousCommandsExportLogsPart4DUnitTest.java | 27 +-
.../cli/commands/QueueCommandsDUnitTest.java | 33 +-
.../SharedConfigurationCommandsDUnitTest.java | 33 +-
.../cli/commands/ShellCommandsDUnitTest.java | 21 +-
.../cli/commands/ShowMetricsDUnitTest.java | 30 +-
.../cli/commands/ShowStackTraceDUnitTest.java | 24 +-
.../cli/commands/UserCommandsDUnitTest.java | 23 +-
.../cli/commands/ClientCommandsDUnitTest.java | 39 +-
.../DurableClientCommandsDUnitTest.java | 23 +-
.../wan/wancommand/WANCommandTestBase.java | 115 +++---
...anCommandCreateGatewayReceiverDUnitTest.java | 177 ++++-----
.../WanCommandCreateGatewaySenderDUnitTest.java | 195 +++++-----
...WanCommandGatewayReceiverStartDUnitTest.java | 133 +++----
.../WanCommandGatewayReceiverStopDUnitTest.java | 133 +++----
.../WanCommandGatewaySenderStartDUnitTest.java | 169 ++++-----
.../WanCommandGatewaySenderStopDUnitTest.java | 171 ++++-----
.../wan/wancommand/WanCommandListDUnitTest.java | 129 +++----
.../WanCommandPauseResumeDUnitTest.java | 367 ++++++++++---------
.../wancommand/WanCommandStatusDUnitTest.java | 185 +++++-----
.../ClusterConfigurationDUnitTest.java | 45 +--
42 files changed, 1465 insertions(+), 1482 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/LauncherLifecycleCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/LauncherLifecycleCommandsDUnitTest.java b/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/LauncherLifecycleCommandsDUnitTest.java
index a78e0ea..e857ce7 100644
--- a/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/LauncherLifecycleCommandsDUnitTest.java
+++ b/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/LauncherLifecycleCommandsDUnitTest.java
@@ -16,43 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.BufferedReader;
-import java.io.BufferedWriter;
-import java.io.File;
-import java.io.FileFilter;
-import java.io.FileOutputStream;
-import java.io.FileReader;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.io.OutputStreamWriter;
-import java.lang.management.ManagementFactory;
-import java.net.InetAddress;
-import java.nio.charset.Charset;
-import java.text.DateFormat;
-import java.text.MessageFormat;
-import java.text.SimpleDateFormat;
-import java.util.Calendar;
-import java.util.Queue;
-import java.util.Set;
-import java.util.concurrent.ConcurrentLinkedDeque;
-import java.util.concurrent.TimeUnit;
-import javax.management.MBeanServerConnection;
-import javax.management.ObjectName;
-import javax.management.Query;
-import javax.management.QueryExp;
-import javax.management.remote.JMXConnector;
-import javax.management.remote.JMXConnectorFactory;
-import javax.management.remote.JMXServiceURL;
-
-import org.junit.FixMethodOrder;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-import org.junit.runners.MethodSorters;
-
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.client.ClientCache;
import com.gemstone.gemfire.cache.client.ClientCacheFactory;
@@ -82,6 +45,42 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.util.CommandStringBuilder;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.FixMethodOrder;
+import org.junit.Ignore;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+import org.junit.runners.MethodSorters;
+
+import javax.management.MBeanServerConnection;
+import javax.management.ObjectName;
+import javax.management.Query;
+import javax.management.QueryExp;
+import javax.management.remote.JMXConnector;
+import javax.management.remote.JMXConnectorFactory;
+import javax.management.remote.JMXServiceURL;
+import java.io.BufferedReader;
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileFilter;
+import java.io.FileOutputStream;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.lang.management.ManagementFactory;
+import java.net.InetAddress;
+import java.nio.charset.Charset;
+import java.text.DateFormat;
+import java.text.MessageFormat;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Queue;
+import java.util.Set;
+import java.util.concurrent.ConcurrentLinkedDeque;
+import java.util.concurrent.TimeUnit;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* The LauncherLifecycleCommandsDUnitTest class is a test suite of integration tests testing the contract and
@@ -109,6 +108,10 @@ public class LauncherLifecycleCommandsDUnitTest extends CliCommandTestBase {
private final Queue<Integer> processIds = new ConcurrentLinkedDeque<>();
+ public LauncherLifecycleCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
protected static String getMemberId(final int jmxManagerPort, final String memberName) throws Exception {
return getMemberId(InetAddress.getLocalHost().getHostName(), jmxManagerPort, memberName);
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/configuration/SharedConfigurationEndToEndDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/configuration/SharedConfigurationEndToEndDUnitTest.java b/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/configuration/SharedConfigurationEndToEndDUnitTest.java
index e1093a2..2583649 100644
--- a/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/configuration/SharedConfigurationEndToEndDUnitTest.java
+++ b/geode-assembly/src/test/java/com/gemstone/gemfire/management/internal/configuration/SharedConfigurationEndToEndDUnitTest.java
@@ -16,14 +16,9 @@
*/
package com.gemstone.gemfire.management.internal.configuration;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheFactory;
import com.gemstone.gemfire.cache.RegionShortcut;
-
import com.gemstone.gemfire.cache.wan.GatewaySender.OrderPolicy;
import com.gemstone.gemfire.distributed.Locator;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
@@ -48,7 +43,6 @@ import com.gemstone.gemfire.test.dunit.SerializableCallable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
-
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import org.junit.experimental.categories.Category;
@@ -62,6 +56,10 @@ import java.util.Properties;
import java.util.Set;
import java.util.concurrent.ExecutionException;
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
+
@Category(DistributedTest.class)
public class SharedConfigurationEndToEndDUnitTest extends CliCommandTestBase {
private static final int TIMEOUT = 10000;
@@ -75,6 +73,10 @@ public class SharedConfigurationEndToEndDUnitTest extends CliCommandTestBase {
private static final long serialVersionUID = -2276690105585944041L;
+ public SharedConfigurationEndToEndDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
public Set<String> startServers(HeadlessGfsh gfsh, String locatorString, int numServers, String serverNamePrefix, int startNum) throws ClassNotFoundException, IOException {
Set<String> serverNames = new HashSet<String>();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/main/java/com/gemstone/gemfire/management/internal/security/ManagementInterceptor.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/com/gemstone/gemfire/management/internal/security/ManagementInterceptor.java b/geode-core/src/main/java/com/gemstone/gemfire/management/internal/security/ManagementInterceptor.java
index 639677b..6ee9da5 100644
--- a/geode-core/src/main/java/com/gemstone/gemfire/management/internal/security/ManagementInterceptor.java
+++ b/geode-core/src/main/java/com/gemstone/gemfire/management/internal/security/ManagementInterceptor.java
@@ -51,21 +51,20 @@ import static com.gemstone.gemfire.management.internal.security.ResourceConstant
import static com.gemstone.gemfire.management.internal.security.ResourceConstants.WRONGE_CREDENTIALS_MESSAGE;
/**
- *
* ManagementInterceptor is central go-to place for all M&M Clients Authentication and Authorization
* requests
- * @since 9.0
*
+ * @since 9.0
*/
public class ManagementInterceptor implements JMXAuthenticator {
// FIXME: Merged from GEODE-17. Are they necessary?
- public static final String USER_NAME = "security-username";
- public static final String PASSWORD = "security-password";
- public static final String OBJECT_NAME_ACCESSCONTROL = "GemFire:service=AccessControl,type=Distributed";
+ public static final String USER_NAME = "security-username";
+ public static final String PASSWORD = "security-password";
+ public static final String OBJECT_NAME_ACCESSCONTROL = "GemFire:service=AccessControl,type=Distributed";
- private static final Logger logger = LogManager.getLogger(ManagementInterceptor.class);
-// private Cache cache;
+ private static final Logger logger = LogManager.getLogger(ManagementInterceptor.class);
+ // private Cache cache;
private String authzFactoryName;
private String postAuthzFactoryName;
private String authenticatorFactoryName;
@@ -80,34 +79,34 @@ public class ManagementInterceptor implements JMXAuthenticator {
this.authenticatorFactoryName = sysProps.getProperty(DistributionConfig.SECURITY_CLIENT_AUTHENTICATOR_NAME);
this.cachedAuthZCallback = new ConcurrentHashMap<>();
this.cachedPostAuthZCallback = new ConcurrentHashMap<>();
- registerAccessControlMBean();
+ registerAccessControlMBean();
logger.info("Started Management interceptor on JMX connector");
- }
+ }
/**
* This method registers an AccessControlMBean which allows any remote JMX Client (for example Pulse) to check for
* access allowed for given Operation Code.
*/
- private void registerAccessControlMBean() {
+ private void registerAccessControlMBean() {
try {
AccessControlMBean acc = new AccessControlMBean(this);
ObjectName accessControlMBeanON = new ObjectName(ResourceConstants.OBJECT_NAME_ACCESSCONTROL);
MBeanServer platformMBeanServer = ManagementFactory.getPlatformMBeanServer();
Set<ObjectName> names = platformMBeanServer.queryNames(accessControlMBeanON, null);
- if(names.isEmpty()) {
+ if (names.isEmpty()) {
try {
platformMBeanServer.registerMBean(acc, accessControlMBeanON);
logger.info("Registered AccessContorlMBean on " + accessControlMBeanON);
} catch (InstanceAlreadyExistsException e) {
- throw new GemFireConfigException("Error while configuring accesscontrol for jmx resource",e);
+ throw new GemFireConfigException("Error while configuring accesscontrol for jmx resource", e);
} catch (MBeanRegistrationException e) {
- throw new GemFireConfigException("Error while configuring accesscontrol for jmx resource",e);
+ throw new GemFireConfigException("Error while configuring accesscontrol for jmx resource", e);
} catch (NotCompliantMBeanException e) {
- throw new GemFireConfigException("Error while configuring accesscontrol for jmx resource",e);
+ throw new GemFireConfigException("Error while configuring accesscontrol for jmx resource", e);
}
}
- } catch (MalformedObjectNameException e) {
+ } catch (MalformedObjectNameException e) {
throw new GemFireConfigException("Error while configuring accesscontrol for jmx resource", e);
}
}
@@ -115,19 +114,18 @@ public class ManagementInterceptor implements JMXAuthenticator {
/**
* Delegates authentication to GemFire Authenticator
*
- * @throws SecurityException
- * if authentication fails
+ * @throws SecurityException if authentication fails
*/
@Override
- public Subject authenticate(Object credentials) {
- String username = null, password = null;
+ public Subject authenticate(Object credentials) {
+ String username = null, password = null;
Properties pr = new Properties();
if (credentials instanceof String[]) {
- final String[] aCredentials = (String[]) credentials;
- username = aCredentials[0];
- password = aCredentials[1];
- pr.put(USER_NAME, username);
- pr.put(PASSWORD, password);
+ final String[] aCredentials = (String[]) credentials;
+ username = aCredentials[0];
+ password = aCredentials[1];
+ pr.put(USER_NAME, username);
+ pr.put(PASSWORD, password);
} else if (credentials instanceof Properties) {
pr = (Properties) credentials;
} else {
@@ -137,12 +135,12 @@ public class ManagementInterceptor implements JMXAuthenticator {
try {
Principal principal = getAuthenticator(sysProps).authenticate(pr);
return new Subject(true, Collections.singleton(new JMXPrincipal(principal.getName())), Collections.EMPTY_SET,
- Collections.EMPTY_SET);
+ Collections.EMPTY_SET);
} catch (AuthenticationFailedException e) {
//wrap inside Security exception. AuthenticationFailedException is gemfire class
//which generic JMX client can't serialize
throw new SecurityException("Authentication Failed " + e.getMessage());
- }
+ }
}
@@ -150,11 +148,10 @@ public class ManagementInterceptor implements JMXAuthenticator {
* Builds ResourceOperationContext for the given JMX MBean Request for delegates Authorization to
* gemfire AccessControl plugin with context as parameter
*
- * @throws SecurityException
- * if access is not granted
+ * @throws SecurityException if access is not granted
*/
public void authorize(ResourceOperationContext context) {
- if (StringUtils.isBlank(authzFactoryName)){
+ if (StringUtils.isBlank(authzFactoryName)) {
return;
}
@@ -164,14 +161,14 @@ public class ManagementInterceptor implements JMXAuthenticator {
if (principals == null || principals.isEmpty()) {
throw new SecurityException(ACCESS_DENIED_MESSAGE + ": No principal found.");
- }
+ }
- Principal principal = principals.iterator().next();
+ Principal principal = principals.iterator().next();
AccessControl accessControl = getAccessControl(principal, false);
if (!accessControl.authorizeOperation(null, context)) {
- throw new SecurityException(ACCESS_DENIED_MESSAGE + ": Not authorized for "+context);
+ throw new SecurityException(ACCESS_DENIED_MESSAGE + ": Not authorized for " + context);
}
}
@@ -180,56 +177,54 @@ public class ManagementInterceptor implements JMXAuthenticator {
if (cachedAuthZCallback.containsKey(principal)) {
return cachedAuthZCallback.get(principal);
} else if (!StringUtils.isBlank(authzFactoryName)) {
- try {
+ try {
Method authzMethod = ClassLoadUtil.methodFromName(authzFactoryName);
AccessControl authzCallback = (AccessControl) authzMethod.invoke(null, (Object[]) null);
- authzCallback.init(principal, null);
+ authzCallback.init(principal);
cachedAuthZCallback.put(principal, authzCallback);
return authzCallback;
} catch (Exception ex) {
- throw new AuthenticationFailedException(
- LocalizedStrings.HandShake_FAILED_TO_ACQUIRE_AUTHENTICATOR_OBJECT.toLocalizedString(), ex);
- }
- }
+ throw new AuthenticationFailedException(LocalizedStrings.HandShake_FAILED_TO_ACQUIRE_AUTHENTICATOR_OBJECT.toLocalizedString(), ex);
+ }
+ }
} else {
if (cachedPostAuthZCallback.containsKey(principal)) {
return cachedPostAuthZCallback.get(principal);
} else if (!StringUtils.isBlank(postAuthzFactoryName)) {
- try {
+ try {
Method authzMethod = ClassLoadUtil.methodFromName(postAuthzFactoryName);
AccessControl postAuthzCallback = (AccessControl) authzMethod.invoke(null, (Object[]) null);
- postAuthzCallback.init(principal, null);
+ postAuthzCallback.init(principal);
cachedPostAuthZCallback.put(principal, postAuthzCallback);
return postAuthzCallback;
} catch (Exception ex) {
- throw new AuthenticationFailedException(
- LocalizedStrings.HandShake_FAILED_TO_ACQUIRE_AUTHENTICATOR_OBJECT.toLocalizedString(), ex);
- }
- }
+ throw new AuthenticationFailedException(LocalizedStrings.HandShake_FAILED_TO_ACQUIRE_AUTHENTICATOR_OBJECT.toLocalizedString(), ex);
+ }
+ }
}
return null;
}
private Authenticator getAuthenticator(Properties gfSecurityProperties) throws AuthenticationFailedException {
Authenticator auth;
- try {
+ try {
Method instanceGetter = ClassLoadUtil.methodFromName(this.authenticatorFactoryName);
auth = (Authenticator) instanceGetter.invoke(null, (Object[]) null);
} catch (Exception ex) {
throw new AuthenticationFailedException(
LocalizedStrings.HandShake_FAILED_TO_ACQUIRE_AUTHENTICATOR_OBJECT.toLocalizedString(), ex);
- }
+ }
if (auth == null) {
throw new AuthenticationFailedException(
LocalizedStrings.HandShake_AUTHENTICATOR_INSTANCE_COULD_NOT_BE_OBTAINED.toLocalizedString());
- }
+ }
auth.init(gfSecurityProperties);
return auth;
- }
+ }
public void postAuthorize(ResourceOperationContext context) {
- if (StringUtils.isBlank(postAuthzFactoryName)){
- return ;
+ if (StringUtils.isBlank(postAuthzFactoryName)) {
+ return;
}
AccessControlContext acc = AccessController.getContext();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CliCommandTestBase.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CliCommandTestBase.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CliCommandTestBase.java
index 6d2b3be..02cf8b7 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CliCommandTestBase.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CliCommandTestBase.java
@@ -31,7 +31,8 @@ import com.gemstone.gemfire.management.internal.security.JSONAuthorization;
import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.cache.internal.JUnit4CacheTestCase;
-import org.json.JSONException;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
import java.io.IOException;
import java.io.PrintStream;
@@ -39,6 +40,8 @@ import java.io.PrintWriter;
import java.io.StringWriter;
import java.net.InetAddress;
import java.net.UnknownHostException;
+import java.util.Arrays;
+import java.util.Collection;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
@@ -51,25 +54,38 @@ import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* Base class for all the CLI/gfsh command dunit tests.
*/
-public class CliCommandTestBase extends JUnit4CacheTestCase {
+@RunWith(Parameterized.class)
+public abstract class CliCommandTestBase extends JUnit4CacheTestCase {
private static final long serialVersionUID = 1L;
- public static final String USE_HTTP_SYSTEM_PROPERTY = "useHTTP";
- public static final String JSON_AUTHORIZATION_SYSTEM_PROPERTY = "jsonAuthorization";
-
private ManagementService managementService;
private transient HeadlessGfsh shell;
- private boolean useHttpOnConnect = Boolean.getBoolean(USE_HTTP_SYSTEM_PROPERTY);
- private String jsonAuthorization = System.getProperty(JSON_AUTHORIZATION_SYSTEM_PROPERTY);
+ protected boolean useHttpOnConnect;
+ protected String jsonAuthorization;
private int httpPort;
private int jmxPort;
private String jmxHost;
+ public CliCommandTestBase(boolean useHttpOnConnect, String jsonAuthorization){
+ this.useHttpOnConnect = useHttpOnConnect;
+ this.jsonAuthorization = jsonAuthorization;
+ }
+
+ @Parameterized.Parameters
+ public static Collection parameters() {
+ return Arrays.asList(new Object[][] {
+ { false, null },
+ { true, null },
+ { false, "cacheServer.json" },
+ { true, "cacheServer.json" }
+ });
+ }
+
@Override
public final void preTearDownCacheTestCase() throws Exception {
preTearDownCliCommandTestBase();
@@ -92,7 +108,6 @@ public class CliCommandTestBase extends JUnit4CacheTestCase {
*/
@SuppressWarnings("serial")
protected HeadlessGfsh createDefaultSetup(final Properties props) {
- final String json = System.getProperty("jsonAuthorization");
Object[] result = (Object[]) Host.getHost(0).getVM(0).invoke( "createDefaultSetup", () -> {
final Object[] results = new Object[3];
final Properties localProps = (props != null ? props : new Properties());
@@ -118,18 +133,12 @@ public class CliCommandTestBase extends JUnit4CacheTestCase {
localProps.setProperty(DistributionConfig.JMX_MANAGER_PORT_NAME, String.valueOf(jmxPort));
localProps.setProperty(DistributionConfig.HTTP_SERVICE_PORT_NAME, String.valueOf(httpPort));
- if(json!=null){
+ if(jsonAuthorization!=null){
localProps.put(DistributionConfig.SECURITY_CLIENT_AUTHENTICATOR_NAME,
JSONAuthorization.class.getName() + ".create");
localProps.put(DistributionConfig.SECURITY_CLIENT_ACCESSOR_NAME, JSONAuthorization.class.getName() + ".create");
- try {
- JSONAuthorization.setUpWithJsonFile(json);
- } catch (IOException e) {
- e.printStackTrace();
- } catch (JSONException e) {
- e.printStackTrace();
- }
+ JSONAuthorization.setUpWithJsonFile(jsonAuthorization);
}
getSystem(localProps);
@@ -246,6 +255,7 @@ public class CliCommandTestBase extends JUnit4CacheTestCase {
endpoint = host + "[" + jmxPort + "]";
command.addOption(CliStrings.CONNECT__JMX_MANAGER, endpoint);
}
+ System.out.println(getClass().getSimpleName()+" using endpoint: "+endpoint);
CommandResult result = executeCommand(shell, command.toString());
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpDunitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpDunitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpDunitTest.java
deleted file mode 100644
index 6baf19c..0000000
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpDunitTest.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package com.gemstone.gemfire.management.internal.cli.commands;
-
-import com.gemstone.gemfire.test.junit.categories.DistributedTest;
-import org.junit.ClassRule;
-import org.junit.contrib.java.lang.system.ProvideSystemProperty;
-import org.junit.experimental.categories.Category;
-import org.junit.runner.RunWith;
-import org.junit.runners.Suite;
-
-@Category(DistributedTest.class)
-
-@RunWith(Suite.class)
-@Suite.SuiteClasses({
- ConfigCommandsDUnitTest.class,
- DeployCommandsDUnitTest.class,
- DiskStoreCommandsDUnitTest.class,
- FunctionCommandsDUnitTest.class,
- GemfireDataCommandsDUnitTest.class,
- GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest.class,
- IndexCommandsDUnitTest.class,
- ListAndDescribeDiskStoreCommandsDUnitTest.class,
- ListIndexCommandDUnitTest.class,
- MemberCommandsDUnitTest.class,
- MiscellaneousCommandsDUnitTest.class,
- MiscellaneousCommandsExportLogsPart1DUnitTest.class,
- MiscellaneousCommandsExportLogsPart2DUnitTest.class,
- MiscellaneousCommandsExportLogsPart3DUnitTest.class,
- MiscellaneousCommandsExportLogsPart4DUnitTest.class,
- QueueCommandsDUnitTest.class,
- SharedConfigurationCommandsDUnitTest.class,
- ShellCommandsDUnitTest.class,
- ShowDeadlockDUnitTest.class,
- ShowMetricsDUnitTest.class,
- ShowStackTraceDUnitTest.class,
- UserCommandsDUnitTest.class
-})
-public class CommandOverHttpDunitTest {
- @ClassRule
- public static ProvideSystemProperty provideSystemProperty = new ProvideSystemProperty(CliCommandTestBase.USE_HTTP_SYSTEM_PROPERTY, "true");
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpSecurityDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpSecurityDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpSecurityDUnitTest.java
deleted file mode 100644
index b3de388..0000000
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CommandOverHttpSecurityDUnitTest.java
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package com.gemstone.gemfire.management.internal.cli.commands;
-
-import com.gemstone.gemfire.test.junit.categories.DistributedTest;
-import org.junit.ClassRule;
-import org.junit.contrib.java.lang.system.ProvideSystemProperty;
-import org.junit.experimental.categories.Category;
-import org.junit.runner.RunWith;
-import org.junit.runners.Suite;
-
-@Category(DistributedTest.class)
-
-@RunWith(Suite.class)
-@Suite.SuiteClasses({
- ConfigCommandsDUnitTest.class,
- DeployCommandsDUnitTest.class,
- DiskStoreCommandsDUnitTest.class,
- FunctionCommandsDUnitTest.class,
- GemfireDataCommandsDUnitTest.class,
- GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest.class,
- IndexCommandsDUnitTest.class,
- ListAndDescribeDiskStoreCommandsDUnitTest.class,
- ListIndexCommandDUnitTest.class,
- MemberCommandsDUnitTest.class,
- MiscellaneousCommandsDUnitTest.class,
- MiscellaneousCommandsExportLogsPart1DUnitTest.class,
- MiscellaneousCommandsExportLogsPart2DUnitTest.class,
- MiscellaneousCommandsExportLogsPart3DUnitTest.class,
- MiscellaneousCommandsExportLogsPart4DUnitTest.class,
- QueueCommandsDUnitTest.class,
- SharedConfigurationCommandsDUnitTest.class,
- ShellCommandsDUnitTest.class,
- ShowDeadlockDUnitTest.class,
- ShowMetricsDUnitTest.class,
- ShowStackTraceDUnitTest.class,
- UserCommandsDUnitTest.class
-})
-public class CommandOverHttpSecurityDUnitTest {
- @ClassRule
- public static ProvideSystemProperty systemProperty = new ProvideSystemProperty(CliCommandTestBase.USE_HTTP_SYSTEM_PROPERTY, "true");
-
- @ClassRule
- public static ProvideSystemProperty securityRule = new ProvideSystemProperty(CliCommandTestBase.JSON_AUTHORIZATION_SYSTEM_PROPERTY, "cacheServer.json");
-
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ConfigCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ConfigCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ConfigCommandsDUnitTest.java
index 9844d90..8481688 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ConfigCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ConfigCommandsDUnitTest.java
@@ -16,26 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.Invoke.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
-import java.io.PrintWriter;
-import java.io.StringWriter;
-import java.lang.management.ManagementFactory;
-import java.lang.management.RuntimeMXBean;
-import java.util.Collections;
-import java.util.List;
-import java.util.Properties;
-
-import org.apache.commons.io.FileUtils;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.server.CacheServer;
import com.gemstone.gemfire.distributed.Locator;
@@ -61,6 +41,25 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.apache.commons.io.FileUtils;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.FileReader;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.io.StringWriter;
+import java.lang.management.ManagementFactory;
+import java.lang.management.RuntimeMXBean;
+import java.util.Collections;
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.Invoke.invokeInEveryVM;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* Dunit class for testing GemFire config commands : export config
@@ -82,6 +81,10 @@ public class ConfigCommandsDUnitTest extends CliCommandTestBase {
File subDir = new File("ConfigCommandsDUnitTestSubDir");
File subManagerConfigFile = new File(subDir, managerConfigFile.getName());
+ public ConfigCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Override
protected void preTearDownCliCommandTestBase() throws Exception {
deleteTestFiles();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CreateAlterDestroyRegionCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CreateAlterDestroyRegionCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CreateAlterDestroyRegionCommandsDUnitTest.java
index b6692c7..0718f53 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CreateAlterDestroyRegionCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/CreateAlterDestroyRegionCommandsDUnitTest.java
@@ -16,30 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.jayway.awaitility.Awaitility.*;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.text.MessageFormat;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Properties;
-import java.util.concurrent.Callable;
-import java.util.concurrent.CopyOnWriteArrayList;
-import java.util.concurrent.TimeUnit;
-import javax.management.MBeanServer;
-import javax.management.MalformedObjectNameException;
-import javax.management.ObjectName;
-
-import org.junit.Ignore;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.PartitionAttributesFactory;
import com.gemstone.gemfire.cache.Region;
@@ -72,6 +48,29 @@ import com.gemstone.gemfire.test.junit.Retry;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
import com.gemstone.gemfire.test.junit.categories.FlakyTest;
import com.gemstone.gemfire.test.junit.rules.RetryRule;
+import org.junit.Ignore;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import javax.management.MBeanServer;
+import javax.management.MalformedObjectNameException;
+import javax.management.ObjectName;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.text.MessageFormat;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Properties;
+import java.util.concurrent.Callable;
+import java.util.concurrent.CopyOnWriteArrayList;
+import java.util.concurrent.TimeUnit;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.jayway.awaitility.Awaitility.waitAtMost;
@Category({ DistributedTest.class, FlakyTest.class }) // GEODE-973
public class CreateAlterDestroyRegionCommandsDUnitTest extends CliCommandTestBase {
@@ -96,6 +95,10 @@ public class CreateAlterDestroyRegionCommandsDUnitTest extends CliCommandTestBas
@Rule
public RetryRule retryRule = new RetryRule();
+ public CreateAlterDestroyRegionCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization){
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
/**
* Asserts that the "compressor" option for the "create region" command succeeds for a recognized compressor.
*/
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DeployCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DeployCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DeployCommandsDUnitTest.java
index fee3978..1888872 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DeployCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DeployCommandsDUnitTest.java
@@ -16,17 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-
-import java.io.File;
-import java.io.FilenameFilter;
-import java.io.IOException;
-import java.util.Properties;
-import java.util.regex.Pattern;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.Locator;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.distributed.internal.DistributionManager;
@@ -47,6 +36,16 @@ import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.Wait;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.FilenameFilter;
+import java.io.IOException;
+import java.util.Properties;
+import java.util.regex.Pattern;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
/**
* Unit tests for the DeployCommands class
@@ -62,6 +61,10 @@ public class DeployCommandsDUnitTest extends CliCommandTestBase {
transient private ClassBuilder classBuilder = new ClassBuilder();
transient private CommandProcessor commandProcessor;
+ public DeployCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization){
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Override
public final void postSetUp() throws Exception {
this.commandProcessor = new CommandProcessor();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsDUnitTest.java
index e8ee713..a8e667b 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsDUnitTest.java
@@ -16,23 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.Collection;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.StringTokenizer;
-import java.util.concurrent.CopyOnWriteArrayList;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheFactory;
import com.gemstone.gemfire.cache.DataPolicy;
@@ -69,6 +52,22 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import java.util.StringTokenizer;
+import java.util.concurrent.CopyOnWriteArrayList;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* The DiskStoreCommandsDUnitTest class is a distributed test suite of test cases for testing the disk store commands
@@ -85,6 +84,10 @@ public class DiskStoreCommandsDUnitTest extends CliCommandTestBase {
final List<String> filesToBeDeleted = new CopyOnWriteArrayList<String>();
+ public DiskStoreCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization){
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Test
public void testMissingDiskStore() {
final String regionName = "testShowMissingDiskStoreRegion";
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsJUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsJUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsJUnitTest.java
index 788e9eb..a6f616c 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsJUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DiskStoreCommandsJUnitTest.java
@@ -16,23 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static org.junit.Assert.*;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.List;
-import java.util.Set;
-
-import org.jmock.Expectations;
-import org.jmock.Mockery;
-import org.jmock.lib.legacy.ClassImposteriser;
-import org.junit.After;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.execute.Execution;
import com.gemstone.gemfire.cache.execute.FunctionInvocationTargetException;
@@ -47,6 +30,22 @@ import com.gemstone.gemfire.management.internal.cli.i18n.CliStrings;
import com.gemstone.gemfire.management.internal.cli.util.DiskStoreNotFoundException;
import com.gemstone.gemfire.management.internal.cli.util.MemberNotFoundException;
import com.gemstone.gemfire.test.junit.categories.UnitTest;
+import org.jmock.Expectations;
+import org.jmock.Mockery;
+import org.jmock.lib.legacy.ClassImposteriser;
+import org.junit.After;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+import java.util.Set;
+
+import static org.junit.Assert.*;
/**
* The DiskStoreCommandsJUnitTest class is a test suite of test cases testing the contract and functionality of the
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/FunctionCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/FunctionCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/FunctionCommandsDUnitTest.java
index b4d4df1..6c89247 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/FunctionCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/FunctionCommandsDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionFactory;
@@ -47,6 +37,15 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* Dunit class for testing gemfire function commands : execute function, destroy function, list function
@@ -59,6 +58,10 @@ public class FunctionCommandsDUnitTest extends CliCommandTestBase {
private static final String REGION_ONE = "RegionOne";
private static final String REGION_TWO = "RegionTwo";
+ public FunctionCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization){
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
void setupWith2Regions() {
final VM vm1 = Host.getHost(0).getVM(1);
final VM vm2 = Host.getHost(0).getVM(2);
@@ -130,8 +133,8 @@ public class FunctionCommandsDUnitTest extends CliCommandTestBase {
}
- public static String getMemberId() {
- Cache cache = new FunctionCommandsDUnitTest().getCache(); // TODO: get rid of this kind of stuff
+ public String getMemberId() {
+ Cache cache = getCache();
return cache.getDistributedSystem().getDistributedMember().getId();
}
@@ -250,7 +253,7 @@ public class FunctionCommandsDUnitTest extends CliCommandTestBase {
Function function = new TestFunction(true, TestFunction.TEST_FUNCTION1);
FunctionService.registerFunction(function);
final VM vm1 = Host.getHost(0).getVM(1);
- final String vm1MemberId = (String) vm1.invoke(() -> FunctionCommandsDUnitTest.getMemberId());
+ final String vm1MemberId = (String) vm1.invoke(() -> getMemberId());
Host.getHost(0).getVM(0).invoke(new SerializableRunnable() {
public void run() {
@@ -407,7 +410,7 @@ public class FunctionCommandsDUnitTest extends CliCommandTestBase {
Function function = new TestFunction(true, TestFunction.TEST_FUNCTION1);
FunctionService.registerFunction(function);
final VM vm1 = Host.getHost(0).getVM(1);
- final String vm1MemberId = (String) vm1.invoke(() -> FunctionCommandsDUnitTest.getMemberId());
+ final String vm1MemberId = (String) vm1.invoke(() -> getMemberId());
String command = "destroy function --id=" + function.getId() + " --member=" + vm1MemberId;
getLogWriter().info("testDestroyOnMember command=" + command);
CommandResult cmdResult = executeCommand(command);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GemfireDataCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GemfireDataCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GemfireDataCommandsDUnitTest.java
index 1b0c9cf..d07b33e 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GemfireDataCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GemfireDataCommandsDUnitTest.java
@@ -16,26 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.IgnoredException.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.Random;
-import java.util.Set;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheFactory;
import com.gemstone.gemfire.cache.DataPolicy;
@@ -81,6 +61,25 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import java.util.Random;
+import java.util.Set;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.IgnoredException.addIgnoredException;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* Dunit class for testing gemfire data commands : get, put, remove, select, rebalance
@@ -119,8 +118,12 @@ public class GemfireDataCommandsDUnitTest extends CliCommandTestBase {
final static int COUNT = 5;
- public static String getMemberId() {
- Cache cache = new GemfireDataCommandsDUnitTest().getCache();
+ public GemfireDataCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization){
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
+ public String getMemberId() {
+ Cache cache = getCache();
return cache.getDistributedSystem().getDistributedMember().getId();
}
@@ -200,8 +203,8 @@ public class GemfireDataCommandsDUnitTest extends CliCommandTestBase {
}
});
- final String vm1MemberId = (String) vm1.invoke(() -> GemfireDataCommandsDUnitTest.getMemberId());
- final String vm2MemberId = (String) vm2.invoke(() -> GemfireDataCommandsDUnitTest.getMemberId());
+ final String vm1MemberId = (String) vm1.invoke(() -> getMemberId());
+ final String vm2MemberId = (String) vm2.invoke(() -> getMemberId());
getLogWriter().info("Vm1 ID : " + vm1MemberId);
getLogWriter().info("Vm2 ID : " + vm2MemberId);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest.java
index 19a354e..b2e98b5 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest.java
@@ -16,18 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.Serializable;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheLoader;
import com.gemstone.gemfire.cache.CacheLoaderException;
@@ -52,6 +40,17 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* The GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest class is test suite of test cases testing the Gfsh
@@ -71,6 +70,11 @@ public class GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest extends C
private static final String GEMFIRE_LOG_LEVEL = System.getProperty("logLevel", "config");
private static final String USERS_REGION_NAME = "Users";
+
+ public GetCommandOnRegionWithCacheLoaderDuringCacheMissDUnitTest(boolean useHttpOnConnect, String jsonAuthorization){
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
protected static String getRegionPath(final String regionName) {
return (regionName.startsWith(Region.SEPARATOR) ? regionName : String.format("%1$s%2$s", Region.SEPARATOR,
regionName));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/IndexCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/IndexCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/IndexCommandsDUnitTest.java
index 123c3bc..fbe9323 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/IndexCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/IndexCommandsDUnitTest.java
@@ -16,15 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.DataPolicy;
import com.gemstone.gemfire.cache.DiskStoreFactory;
@@ -54,6 +45,14 @@ import com.gemstone.gemfire.test.dunit.Wait;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
import com.gemstone.gemfire.test.junit.categories.FlakyTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
@Category({ DistributedTest.class, FlakyTest.class }) // see GEODE-689, GEODE-1048
public class IndexCommandsDUnitTest extends CliCommandTestBase {
@@ -65,6 +64,10 @@ public class IndexCommandsDUnitTest extends CliCommandTestBase {
private static final String parRegPersName = "ParRegPers";
private static final String repRegPersName = "RepRegPer";
+ public IndexCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
Region<?, ?> createParReg(String regionName, Cache cache, Class keyConstraint, Class valueConstraint) {
RegionFactory regionFactory = cache.createRegionFactory();
regionFactory.setDataPolicy(DataPolicy.PARTITION);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeDiskStoreCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeDiskStoreCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeDiskStoreCommandsDUnitTest.java
index 6466033..0224982 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeDiskStoreCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeDiskStoreCommandsDUnitTest.java
@@ -16,15 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.Serializable;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.DataPolicy;
import com.gemstone.gemfire.cache.DiskStore;
@@ -39,6 +30,16 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.Serializable;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
+import static com.gemstone.gemfire.test.dunit.Assert.assertNotNull;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getDUnitLogLevel;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* The ListAndDescribeDiskStoreCommandsDUnitTest class is a test suite of functional tests cases testing the proper
@@ -51,6 +52,10 @@ import com.gemstone.gemfire.test.junit.categories.DistributedTest;
@Category(DistributedTest.class)
public class ListAndDescribeDiskStoreCommandsDUnitTest extends CliCommandTestBase {
+ public ListAndDescribeDiskStoreCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
protected static String toString(final Result result) {
assert result != null : "The Result object from the command execution cannot be null!";
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeRegionDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeRegionDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeRegionDUnitTest.java
index f495944..bf8e913 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeRegionDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListAndDescribeRegionDUnitTest.java
@@ -16,14 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.EvictionAction;
import com.gemstone.gemfire.cache.EvictionAttributes;
@@ -46,6 +38,13 @@ import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
@Category(DistributedTest.class)
public class ListAndDescribeRegionDUnitTest extends CliCommandTestBase {
@@ -59,6 +58,9 @@ public class ListAndDescribeRegionDUnitTest extends CliCommandTestBase {
private static final String PR1 = "PR1";
private static final String LOCALREGIONONMANAGER = "LocalRegionOnManager";
+ public ListAndDescribeRegionDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
static class CacheListener2 extends CacheListenerAdapter {
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListIndexCommandDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListIndexCommandDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListIndexCommandDUnitTest.java
index deb8860..356445d 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListIndexCommandDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ListIndexCommandDUnitTest.java
@@ -16,24 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.HashSet;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Properties;
-import java.util.Random;
-import java.util.Set;
-import java.util.concurrent.atomic.AtomicLong;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.DataPolicy;
import com.gemstone.gemfire.cache.Region;
@@ -55,6 +37,24 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Properties;
+import java.util.Random;
+import java.util.Set;
+import java.util.concurrent.atomic.AtomicLong;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getDUnitLogLevel;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* The ListIndexCommandDUnitTest class is distributed test suite of test cases for testing the index-based GemFire shell
@@ -72,6 +72,10 @@ public class ListIndexCommandDUnitTest extends CliCommandTestBase {
private final AtomicLong idGenerator = new AtomicLong(0l);
+ public ListIndexCommandDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
protected static String toString(final Result result) {
assert result != null : "The Result object from the command execution cannot be null!";
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsDUnitTest.java
index 1c6f141..b9dcc41 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsDUnitTest.java
@@ -16,20 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.IgnoredException.*;
-import static com.gemstone.gemfire.test.dunit.Invoke.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.IOException;
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheClosedException;
import com.gemstone.gemfire.cache.CacheFactory;
@@ -56,6 +42,19 @@ import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
import com.gemstone.gemfire.test.junit.categories.FlakyTest;
+import org.junit.Ignore;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.IgnoredException.addIgnoredException;
+import static com.gemstone.gemfire.test.dunit.Invoke.invokeInEveryVM;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* Dunit class for testing gemfire function commands : GC, Shutdown
@@ -66,6 +65,10 @@ public class MiscellaneousCommandsDUnitTest extends CliCommandTestBase {
private static final long serialVersionUID = 1L;
private static String cachedLogLevel;
+ public MiscellaneousCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Override
protected final void preTearDownCliCommandTestBase() throws Exception {
invokeInEveryVM(new SerializableRunnable("reset log level") {
@@ -103,8 +106,8 @@ public class MiscellaneousCommandsDUnitTest extends CliCommandTestBase {
}
}
- public static String getMemberId() {
- Cache cache = new GemfireDataCommandsDUnitTest().getCache();
+ public String getMemberId() {
+ Cache cache = getCache();
return cache.getDistributedSystem().getDistributedMember().getId();
}
@@ -112,7 +115,7 @@ public class MiscellaneousCommandsDUnitTest extends CliCommandTestBase {
public void testGCForMemberID() {
createDefaultSetup(null);
final VM vm1 = Host.getHost(0).getVM(1);
- final String vm1MemberId = (String) vm1.invoke(() -> MiscellaneousCommandsDUnitTest.getMemberId());
+ final String vm1MemberId = (String) vm1.invoke(() -> getMemberId());
String command = "gc --member=" + vm1MemberId;
CommandResult cmdResult = executeCommand(command);
cmdResult.resetToFirstLine();
@@ -139,7 +142,7 @@ public class MiscellaneousCommandsDUnitTest extends CliCommandTestBase {
props.setProperty("log-file", "testShowLogDefault.log");
createDefaultSetup(props);
final VM vm1 = Host.getHost(0).getVM(0);
- final String vm1MemberId = (String) vm1.invoke(() -> MiscellaneousCommandsDUnitTest.getMemberId());
+ final String vm1MemberId = (String) vm1.invoke(() -> getMemberId());
String command = "show log --member=" + vm1MemberId;
CommandResult cmdResult = executeCommand(command);
if (cmdResult != null) {
@@ -162,7 +165,7 @@ public class MiscellaneousCommandsDUnitTest extends CliCommandTestBase {
try {
createDefaultSetup(props);
final VM vm1 = Host.getHost(0).getVM(0);
- final String vm1MemberId = (String) vm1.invoke(() -> MiscellaneousCommandsDUnitTest.getMemberId());
+ final String vm1MemberId = (String) vm1.invoke(() -> getMemberId());
String command = "show log --member=" + vm1MemberId + " --lines=50";
CommandResult cmdResult = executeCommand(command);
if (cmdResult != null) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart1DUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart1DUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart1DUnitTest.java
index 60c5ded..0ce955d 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart1DUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart1DUnitTest.java
@@ -16,17 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionFactory;
@@ -39,6 +28,17 @@ import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
+import static com.gemstone.gemfire.test.dunit.Assert.fail;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* Dunit class for testing gemfire function commands : export logs
@@ -48,9 +48,8 @@ public class MiscellaneousCommandsExportLogsPart1DUnitTest extends CliCommandTes
private static final long serialVersionUID = 1L;
- public static String getMemberId() {
- Cache cache = new GemfireDataCommandsDUnitTest().getCache();
- return cache.getDistributedSystem().getDistributedMember().getId();
+ public MiscellaneousCommandsExportLogsPart1DUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
}
void setupForExportLogs() {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart2DUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart2DUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart2DUnitTest.java
index fbe156a..55d8b06 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart2DUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart2DUnitTest.java
@@ -16,17 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionFactory;
@@ -39,6 +28,17 @@ import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
+import static com.gemstone.gemfire.test.dunit.Assert.fail;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* Dunit class for testing gemfire function commands : export logs
@@ -48,11 +48,11 @@ public class MiscellaneousCommandsExportLogsPart2DUnitTest extends CliCommandTes
private static final long serialVersionUID = 1L;
- public static String getMemberId() {
- Cache cache = new GemfireDataCommandsDUnitTest().getCache();
- return cache.getDistributedSystem().getDistributedMember().getId();
+ public MiscellaneousCommandsExportLogsPart2DUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
}
+
void setupForExportLogs() {
final VM vm1 = Host.getHost(0).getVM(1);
createDefaultSetup(null);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart3DUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart3DUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart3DUnitTest.java
index 5c159e8..63f3ceb 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart3DUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart3DUnitTest.java
@@ -16,18 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionFactory;
@@ -41,6 +29,18 @@ import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
+import static com.gemstone.gemfire.test.dunit.Assert.fail;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* Dunit class for testing gemfire function commands : export logs
@@ -50,8 +50,12 @@ public class MiscellaneousCommandsExportLogsPart3DUnitTest extends CliCommandTes
private static final long serialVersionUID = 1L;
- public static String getMemberId() {
- Cache cache = new GemfireDataCommandsDUnitTest().getCache();
+ public MiscellaneousCommandsExportLogsPart3DUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
+ public String getMemberId() {
+ Cache cache = getCache();
return cache.getDistributedSystem().getDistributedMember().getId();
}
@@ -128,7 +132,7 @@ public class MiscellaneousCommandsExportLogsPart3DUnitTest extends CliCommandTes
String end = sf.format(enddate);
final VM vm1 = Host.getHost(0).getVM(1);
- final String vm1MemberId = (String) vm1.invoke(() -> MiscellaneousCommandsDUnitTest.getMemberId());
+ final String vm1MemberId = (String) vm1.invoke(() -> getMemberId());
String dir = getCurrentTimeString();
String logLevel = LogWriterImpl.levelToString(LogWriterImpl.INFO_LEVEL);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart4DUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart4DUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart4DUnitTest.java
index cf19659..4015033 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart4DUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/MiscellaneousCommandsExportLogsPart4DUnitTest.java
@@ -16,17 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionFactory;
@@ -39,6 +28,17 @@ import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
+import static com.gemstone.gemfire.test.dunit.Assert.fail;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* Dunit class for testing gemfire function commands : export logs
@@ -48,9 +48,8 @@ public class MiscellaneousCommandsExportLogsPart4DUnitTest extends CliCommandTes
private static final long serialVersionUID = 1L;
- public static String getMemberId() {
- Cache cache = new GemfireDataCommandsDUnitTest().getCache();
- return cache.getDistributedSystem().getDistributedMember().getId();
+ public MiscellaneousCommandsExportLogsPart4DUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
}
void setupForExportLogs() {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/QueueCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/QueueCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/QueueCommandsDUnitTest.java
index f61ff57..4d23535 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/QueueCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/QueueCommandsDUnitTest.java
@@ -16,21 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.util.List;
-import java.util.Properties;
-import java.util.concurrent.CopyOnWriteArrayList;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.asyncqueue.AsyncEventQueue;
import com.gemstone.gemfire.distributed.Locator;
@@ -49,6 +34,20 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.List;
+import java.util.Properties;
+import java.util.concurrent.CopyOnWriteArrayList;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* A distributed test suite of test cases for testing the queue commands that are part of Gfsh.
@@ -62,6 +61,10 @@ public class QueueCommandsDUnitTest extends CliCommandTestBase {
final List<String> filesToBeDeleted = new CopyOnWriteArrayList<String>();
+ public QueueCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Override
public final void preSetUp() throws Exception {
disconnectAllFromDS();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/SharedConfigurationCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/SharedConfigurationCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/SharedConfigurationCommandsDUnitTest.java
index d3e004b..6407897 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/SharedConfigurationCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/SharedConfigurationCommandsDUnitTest.java
@@ -16,21 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-import java.util.Properties;
-import java.util.Set;
-
-import org.apache.commons.io.FileUtils;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheFactory;
import com.gemstone.gemfire.distributed.DistributedMember;
@@ -55,6 +40,20 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.apache.commons.io.FileUtils;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Properties;
+import java.util.Set;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/***
* DUnit test to test export and import of shared configuration.
@@ -70,6 +69,10 @@ public class SharedConfigurationCommandsDUnitTest extends CliCommandTestBase {
File newDeployableJarFile = new File("DeployCommandsDUnit1.jar");
private transient ClassBuilder classBuilder = new ClassBuilder();
+ public SharedConfigurationCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Test
public void testExportImportSharedConfiguration() {
disconnectAllFromDS();
[3/4] incubator-geode git commit: GEODE-17: refactor
CliCommandTestBase to use Parameterized Junit runs to do all combinations of
http/non-http and security/non-security runs
Posted by ji...@apache.org.
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShellCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShellCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShellCommandsDUnitTest.java
index f5aa506..23ec0a1 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShellCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShellCommandsDUnitTest.java
@@ -16,15 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.File;
-import java.util.concurrent.TimeUnit;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.AbstractLauncher.Status;
import com.gemstone.gemfire.distributed.LocatorLauncher;
import com.gemstone.gemfire.distributed.LocatorLauncher.LocatorState;
@@ -38,12 +29,24 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.shell.Gfsh;
import com.gemstone.gemfire.management.internal.cli.util.CommandStringBuilder;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.util.concurrent.TimeUnit;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
@Category(DistributedTest.class)
public class ShellCommandsDUnitTest extends CliCommandTestBase {
private static final long serialVersionUID = 1L;
+ public ShellCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Override
public final void postSetUp() throws Exception {
getDefaultShell();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowMetricsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowMetricsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowMetricsDUnitTest.java
index c17f7e7..f7c32bc 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowMetricsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowMetricsDUnitTest.java
@@ -16,19 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.Collections;
-import java.util.Properties;
-import javax.management.ObjectName;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.Region;
import com.gemstone.gemfire.cache.RegionFactory;
@@ -54,12 +41,29 @@ import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import javax.management.ObjectName;
+import java.io.File;
+import java.io.IOException;
+import java.util.Collections;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
+import static com.gemstone.gemfire.test.dunit.Assert.assertTrue;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
@Category(DistributedTest.class)
public class ShowMetricsDUnitTest extends CliCommandTestBase {
private static final long serialVersionUID = 1L;
+ public ShowMetricsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
private void createLocalSetUp() {
Properties localProps = new Properties();
localProps.setProperty(DistributionConfig.NAME_NAME, "Controller");
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowStackTraceDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowStackTraceDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowStackTraceDUnitTest.java
index 6a14a40..89a6a17 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowStackTraceDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ShowStackTraceDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.management.cli.Result.Status;
import com.gemstone.gemfire.management.internal.cli.i18n.CliStrings;
@@ -35,6 +25,16 @@ import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertFalse;
+import static com.gemstone.gemfire.test.dunit.Assert.assertTrue;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/***
* DUnit test for 'show stack-trace' command
@@ -44,6 +44,10 @@ public class ShowStackTraceDUnitTest extends CliCommandTestBase {
private static final long serialVersionUID = 1L;
+ public ShowStackTraceDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
private void createCache(Properties props) {
getSystem(props);
getCache();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/UserCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/UserCommandsDUnitTest.java b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/UserCommandsDUnitTest.java
index 3b4db25..a9d670d 100644
--- a/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/UserCommandsDUnitTest.java
+++ b/geode-core/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/UserCommandsDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.internal.ClassBuilder;
import com.gemstone.gemfire.internal.ClassPathLoader;
@@ -36,6 +26,15 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
/**
* Unit tests for configuring user commands.
@@ -52,6 +51,10 @@ public class UserCommandsDUnitTest extends CliCommandTestBase {
final File jarFile = new File(this.jarDirectory, "UserCommandsDUnit.jar");
boolean deleteJarDirectory = false;
+ public UserCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Override
public final void postSetUp() throws Exception {
createUserCommandJarFile();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java
index 6fef000..878d122 100644
--- a/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java
+++ b/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/ClientCommandsDUnitTest.java
@@ -16,23 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.DistributedTestUtils.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.NetworkUtils.*;
-import static com.gemstone.gemfire.test.dunit.Wait.*;
-
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Properties;
-import javax.management.ObjectName;
-
-import org.junit.Ignore;
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.AttributesFactory;
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheException;
@@ -78,6 +61,22 @@ import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
import com.gemstone.gemfire.test.junit.categories.FlakyTest;
+import org.junit.Ignore;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import javax.management.ObjectName;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.DistributedTestUtils.getDUnitLocatorPort;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.NetworkUtils.getServerHostName;
+import static com.gemstone.gemfire.test.dunit.Wait.waitForCriterion;
/**
* Dunit class for testing gemfire Client commands : list client , describe client
@@ -95,7 +94,11 @@ public class ClientCommandsDUnitTest extends CliCommandTestBase {
String clientId = "";
int port0 = 0;
int port1= 0;
-
+
+ public ClientCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
public void waitForListClientMbean(){
final VM manager = Host.getHost(0).getVM(0);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DurableClientCommandsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DurableClientCommandsDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DurableClientCommandsDUnitTest.java
index b35538d..e3d8731 100644
--- a/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DurableClientCommandsDUnitTest.java
+++ b/geode-cq/src/test/java/com/gemstone/gemfire/management/internal/cli/commands/DurableClientCommandsDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.management.internal.cli.commands;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.DistributedTestUtils.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-import static com.gemstone.gemfire.test.dunit.NetworkUtils.*;
-
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.AttributesFactory;
import com.gemstone.gemfire.cache.CacheException;
import com.gemstone.gemfire.cache.DataPolicy;
@@ -56,6 +46,15 @@ import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.SerializableCallable;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertTrue;
+import static com.gemstone.gemfire.test.dunit.DistributedTestUtils.getDUnitLocatorPort;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
+import static com.gemstone.gemfire.test.dunit.NetworkUtils.getServerHostName;
@Category(DistributedTest.class)
public class DurableClientCommandsDUnitTest extends CliCommandTestBase {
@@ -67,6 +66,10 @@ public class DurableClientCommandsDUnitTest extends CliCommandTestBase {
final String cq3 = "cq3";
final String clientName = "dc1";
+ public DurableClientCommandsDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Test
public void testListDurableClientCqs() throws Exception {
setupSystem();
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
index 719fd92..1d685ea 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-
-import java.io.File;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Properties;
-import java.util.Set;
-import javax.management.remote.JMXConnectorServer;
-
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheFactory;
import com.gemstone.gemfire.cache.DiskStore;
@@ -51,7 +41,18 @@ import com.gemstone.gemfire.test.dunit.Invoke;
import com.gemstone.gemfire.test.dunit.SerializableRunnable;
import com.gemstone.gemfire.test.dunit.VM;
-public class WANCommandTestBase extends CliCommandTestBase {
+import javax.management.remote.JMXConnectorServer;
+import java.io.File;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+import java.util.Set;
+
+import static com.gemstone.gemfire.test.dunit.Assert.assertEquals;
+import static com.gemstone.gemfire.test.dunit.Assert.fail;
+
+public abstract class WANCommandTestBase extends CliCommandTestBase {
static Cache cache;
private JMXConnectorServer jmxConnectorServer;
@@ -68,6 +69,10 @@ public class WANCommandTestBase extends CliCommandTestBase {
static VM vm6;
static VM vm7;
+ public WANCommandTestBase(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
@Override
public final void postSetUp() throws Exception {
final Host host = Host.getHost(0);
@@ -82,52 +87,48 @@ public class WANCommandTestBase extends CliCommandTestBase {
enableManagement();
}
- public static Integer createFirstLocatorWithDSId(int dsId) {
- WANCommandTestBase test = new WANCommandTestBase();
+ public Integer createFirstLocatorWithDSId(int dsId) {
int port = AvailablePortHelper.getRandomAvailablePortForDUnitSite();
- Properties props = test.getDistributedSystemProperties();
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME,"0");
props.setProperty(DistributionConfig.DISTRIBUTED_SYSTEM_ID_NAME, ""+dsId);
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + port + "]");
props.setProperty(DistributionConfig.START_LOCATOR_NAME, "localhost[" + port + "],server=true,peer=true,hostname-for-clients=localhost");
- InternalDistributedSystem ds = test.getSystem(props);
+ InternalDistributedSystem ds = getSystem(props);
cache = CacheFactory.create(ds);
return port;
}
- public static Integer createFirstRemoteLocator(int dsId, int remoteLocPort) {
- WANCommandTestBase test = new WANCommandTestBase();
+ public Integer createFirstRemoteLocator(int dsId, int remoteLocPort) {
int port = AvailablePortHelper.getRandomAvailablePortForDUnitSite();
- Properties props = test.getDistributedSystemProperties();
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME,"0");
props.setProperty(DistributionConfig.DISTRIBUTED_SYSTEM_ID_NAME, ""+dsId);
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + port + "]");
props.setProperty(DistributionConfig.START_LOCATOR_NAME, "localhost[" + port + "],server=true,peer=true,hostname-for-clients=localhost");
props.setProperty(DistributionConfig.REMOTE_LOCATORS_NAME, "localhost[" + remoteLocPort + "]");
- test.getSystem(props);
+ getSystem(props);
return port;
}
- public static void createCache(Integer locPort){
- WANCommandTestBase test = new WANCommandTestBase();
- Properties props = test.getDistributedSystemProperties();
+ public void createCache(Integer locPort){
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + locPort + "]");
- InternalDistributedSystem ds = test.getSystem(props);
+ InternalDistributedSystem ds = getSystem(props);
cache = CacheFactory.create(ds);
}
- public static void createCacheWithGroups(Integer locPort, String groups){
- WANCommandTestBase test = new WANCommandTestBase();
- Properties props = test.getDistributedSystemProperties();
+ public void createCacheWithGroups(Integer locPort, String groups){
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + locPort + "]");
props.setProperty(DistributionConfig.GROUPS_NAME, groups);
- InternalDistributedSystem ds = test.getSystem(props);
+ InternalDistributedSystem ds = getSystem(props);
cache = CacheFactory.create(ds);
}
- public static void createSender(String dsName, int remoteDsId,
+ public void createSender(String dsName, int remoteDsId,
boolean isParallel, Integer maxMemory,
Integer batchSize, boolean isConflation, boolean isPersistent,
GatewayEventFilter filter, boolean isManulaStart) {
@@ -176,7 +177,7 @@ public class WANCommandTestBase extends CliCommandTestBase {
}
}
- public static void startSender(String senderId){
+ public void startSender(String senderId){
final IgnoredException exln = IgnoredException.addIgnoredException("Could not connect");
try {
Set<GatewaySender> senders = cache.getGatewaySenders();
@@ -193,7 +194,7 @@ public class WANCommandTestBase extends CliCommandTestBase {
}
}
- public static void pauseSender(String senderId){
+ public void pauseSender(String senderId){
final IgnoredException exln = IgnoredException.addIgnoredException("Could not connect");
try {
Set<GatewaySender> senders = cache.getGatewaySenders();
@@ -210,14 +211,13 @@ public class WANCommandTestBase extends CliCommandTestBase {
}
}
- public static int createAndStartReceiver(int locPort) {
- WANCommandTestBase test = new WANCommandTestBase();
- Properties props = test.getDistributedSystemProperties();
+ public int createAndStartReceiver(int locPort) {
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + locPort
+ "]");
- InternalDistributedSystem ds = test.getSystem(props);
+ InternalDistributedSystem ds = getSystem(props);
cache = CacheFactory.create(ds);
GatewayReceiverFactory fact = cache.createGatewayReceiverFactory();
int port = AvailablePortHelper.getRandomAvailablePortForDUnitSite();
@@ -229,19 +229,18 @@ public class WANCommandTestBase extends CliCommandTestBase {
receiver.start();
} catch (IOException e) {
e.printStackTrace();
- fail("Test " + test.getName() + " failed to start GatewayRecevier");
+ fail("Test " + getName() + " failed to start GatewayRecevier");
}
return port;
}
- public static int createReceiver(int locPort) {
- WANCommandTestBase test = new WANCommandTestBase();
- Properties props = test.getDistributedSystemProperties();
+ public int createReceiver(int locPort) {
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + locPort
+ "]");
- InternalDistributedSystem ds = test.getSystem(props);
+ InternalDistributedSystem ds = getSystem(props);
cache = CacheFactory.create(ds);
GatewayReceiverFactory fact = cache.createGatewayReceiverFactory();
int port = AvailablePortHelper.getRandomAvailablePortForDUnitSite();
@@ -252,15 +251,14 @@ public class WANCommandTestBase extends CliCommandTestBase {
return port;
}
- public static int createReceiverWithGroup(int locPort, String groups) {
- WANCommandTestBase test = new WANCommandTestBase();
- Properties props = test.getDistributedSystemProperties();
+ public int createReceiverWithGroup(int locPort, String groups) {
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + locPort
+ "]");
props.setProperty(DistributionConfig.GROUPS_NAME, groups);
- InternalDistributedSystem ds = test.getSystem(props);
+ InternalDistributedSystem ds = getSystem(props);
cache = CacheFactory.create(ds);
GatewayReceiverFactory fact = cache.createGatewayReceiverFactory();
int port = AvailablePortHelper.getRandomAvailablePortForDUnitSite();
@@ -271,8 +269,7 @@ public class WANCommandTestBase extends CliCommandTestBase {
return port;
}
- public static void startReceiver() {
- WANCommandTestBase test = new WANCommandTestBase();
+ public void startReceiver() {
try {
Set<GatewayReceiver> receivers = cache.getGatewayReceivers();
for (GatewayReceiver receiver : receivers) {
@@ -280,27 +277,25 @@ public class WANCommandTestBase extends CliCommandTestBase {
}
} catch (IOException e) {
e.printStackTrace();
- fail("Test " + test.getName() + " failed to start GatewayRecevier");
+ fail("Test " + getName() + " failed to start GatewayRecevier");
}
}
- public static void stopReceiver() {
- WANCommandTestBase test = new WANCommandTestBase();
+ public void stopReceiver() {
Set<GatewayReceiver> receivers = cache.getGatewayReceivers();
for (GatewayReceiver receiver : receivers) {
receiver.stop();
}
}
- public static int createAndStartReceiverWithGroup(int locPort, String groups) {
- WANCommandTestBase test = new WANCommandTestBase();
- Properties props = test.getDistributedSystemProperties();
+ public int createAndStartReceiverWithGroup(int locPort, String groups) {
+ Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + locPort
+ "]");
props.setProperty(DistributionConfig.GROUPS_NAME, groups);
- InternalDistributedSystem ds = test.getSystem(props);
+ InternalDistributedSystem ds = getSystem(props);
cache = CacheFactory.create(ds);
GatewayReceiverFactory fact = cache.createGatewayReceiverFactory();
int port = AvailablePortHelper.getRandomAvailablePortForDUnitSite();
@@ -312,17 +307,17 @@ public class WANCommandTestBase extends CliCommandTestBase {
receiver.start();
} catch (IOException e) {
e.printStackTrace();
- fail("Test " + test.getName() + " failed to start GatewayRecevier on port " + port);
+ fail("Test " + getName() + " failed to start GatewayRecevier on port " + port);
}
return port;
}
- public static DistributedMember getMember(){
+ public DistributedMember getMember(){
return cache.getDistributedSystem().getDistributedMember();
}
- public static int getLocatorPort(){
+ public int getLocatorPort(){
return Locator.getLocators().get(0).getPort();
}
@@ -338,7 +333,7 @@ public class WANCommandTestBase extends CliCommandTestBase {
}
- public static void verifySenderState(String senderId, boolean isRunning, boolean isPaused) {
+ public void verifySenderState(String senderId, boolean isRunning, boolean isPaused) {
final IgnoredException exln = IgnoredException.addIgnoredException("Could not connect");
try {
Set<GatewaySender> senders = cache.getGatewaySenders();
@@ -357,7 +352,7 @@ public class WANCommandTestBase extends CliCommandTestBase {
}
}
- public static void verifySenderAttributes(String senderId, int remoteDsID,
+ public void verifySenderAttributes(String senderId, int remoteDsID,
boolean isParallel, boolean manualStart, int socketBufferSize,
int socketReadTimeout, boolean enableBatchConflation, int batchSize,
int batchTimeInterval, boolean enablePersistence,
@@ -440,19 +435,17 @@ public class WANCommandTestBase extends CliCommandTestBase {
}
}
- public static void verifyReceiverState(boolean isRunning) {
- WANCommandTestBase test = new WANCommandTestBase();
+ public void verifyReceiverState(boolean isRunning) {
Set<GatewayReceiver> receivers = cache.getGatewayReceivers();
for (GatewayReceiver receiver : receivers) {
assertEquals(isRunning, receiver.isRunning());
}
}
- public static void verifyReceiverCreationWithAttributes(boolean isRunning,
+ public void verifyReceiverCreationWithAttributes(boolean isRunning,
int startPort, int endPort, String bindAddress, int maxTimeBetweenPings,
int socketBufferSize, List<String> expectedGatewayTransportFilters) {
- WANCommandTestBase test = new WANCommandTestBase();
Set<GatewayReceiver> receivers = cache.getGatewayReceivers();
assertEquals("Number of receivers is incorrect", 1, receivers.size());
for (GatewayReceiver receiver : receivers) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java
index d9a551b..a7f1e04 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewayReceiverDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.wan.GatewayReceiver;
import com.gemstone.gemfire.distributed.DistributedMember;
import com.gemstone.gemfire.distributed.internal.DistributionConfig;
@@ -36,6 +26,15 @@ import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
/**
* DUnit tests for 'create gateway-receiver' command.
@@ -44,7 +43,11 @@ import com.gemstone.gemfire.test.junit.categories.DistributedTest;
public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
-
+
+ public WanCommandCreateGatewayReceiverDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
/**
* GatewayReceiver with all default attributes
*/
@@ -52,7 +55,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiverWithDefault() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -60,11 +63,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
String command = CliStrings.CREATE_GATEWAYRECEIVER;
CommandResult cmdResult = executeCommand(command);
@@ -88,19 +91,19 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
fail("testCreateGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START,
GatewayReceiver.DEFAULT_START_PORT,
GatewayReceiver.DEFAULT_END_PORT,
GatewayReceiver.DEFAULT_BIND_ADDRESS,
GatewayReceiver.DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS,
GatewayReceiver.DEFAULT_SOCKET_BUFFER_SIZE, null ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START,
GatewayReceiver.DEFAULT_START_PORT,
GatewayReceiver.DEFAULT_END_PORT,
GatewayReceiver.DEFAULT_BIND_ADDRESS,
GatewayReceiver.DEFAULT_MAXIMUM_TIME_BETWEEN_PINGS,
GatewayReceiver.DEFAULT_SOCKET_BUFFER_SIZE, null ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START,
+ vm5.invoke(() -> verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START,
GatewayReceiver.DEFAULT_START_PORT,
GatewayReceiver.DEFAULT_END_PORT,
GatewayReceiver.DEFAULT_BIND_ADDRESS,
@@ -115,7 +118,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiver() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -123,11 +126,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART+ "=true"
@@ -157,11 +160,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
fail("testCreateGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm5.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
}
@@ -172,7 +175,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiverWithGatewayTransportFilter() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -180,11 +183,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART+ "=false"
@@ -218,11 +221,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
List<String> transportFilters = new ArrayList<String>();
transportFilters.add("com.gemstone.gemfire.cache30.MyGatewayTransportFilter1");
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( true, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( true, 10000,
11000, "localhost", 100000, 512000, transportFilters ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( true, 10000,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( true, 10000,
11000, "localhost", 100000, 512000, transportFilters ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( true, 10000,
+ vm5.invoke(() -> verifyReceiverCreationWithAttributes( true, 10000,
11000, "localhost", 100000, 512000, transportFilters ));
}
@@ -233,7 +236,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiverWithMultipleGatewayTransportFilters() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -241,11 +244,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
String command = CliStrings.CREATE_GATEWAYRECEIVER + " --"
+ CliStrings.CREATE_GATEWAYRECEIVER__BINDADDRESS + "=localhost" + " --"
@@ -281,11 +284,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
transportFilters.add("com.gemstone.gemfire.cache30.MyGatewayTransportFilter1");
transportFilters.add("com.gemstone.gemfire.cache30.MyGatewayTransportFilter2");
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START, 10000,
11000, "localhost", 100000, 512000, transportFilters ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START, 10000,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START, 10000,
11000, "localhost", 100000, 512000, transportFilters ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START, 10000,
+ vm5.invoke(() -> verifyReceiverCreationWithAttributes( !GatewayReceiver.DEFAULT_MANUAL_START, 10000,
11000, "localhost", 100000, 512000, transportFilters ));
}
@@ -297,7 +300,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiver_Error() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -305,11 +308,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__BINDADDRESS + "=localhost"
@@ -346,7 +349,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiver_onMember() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -354,13 +357,13 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
- final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> getMember());
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART + "=true"
@@ -391,7 +394,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
fail("testCreateGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
}
@@ -402,7 +405,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiver_onMultipleMembers() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -410,14 +413,14 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
- final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
- final DistributedMember vm4Member = (DistributedMember) vm4.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> getMember());
+ final DistributedMember vm4Member = (DistributedMember) vm4.invoke(() -> getMember());
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART + "=true"
@@ -448,9 +451,9 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
fail("testCreateGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
}
@@ -461,7 +464,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiver_onGroup() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -469,11 +472,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup1" ));
+ vm3.invoke(() -> createCacheWithGroups( punePort, "receiverGroup1" ));
+ vm4.invoke(() -> createCacheWithGroups( punePort, "receiverGroup1" ));
+ vm5.invoke(() -> createCacheWithGroups( punePort, "receiverGroup1" ));
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART + "=true"
@@ -504,11 +507,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
fail("testCreateGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm5.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
}
@@ -520,7 +523,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiver_onGroup_Scenario2() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -528,11 +531,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup2" ));
+ vm3.invoke(() -> createCacheWithGroups( punePort, "receiverGroup1" ));
+ vm4.invoke(() -> createCacheWithGroups( punePort, "receiverGroup1" ));
+ vm5.invoke(() -> createCacheWithGroups( punePort, "receiverGroup2" ));
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART + "=true"
@@ -563,9 +566,9 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
fail("testCreateGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
}
@@ -576,7 +579,7 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
public void testCreateGatewayReceiver_onMultipleGroups() {
VM puneLocator = Host.getLocator();
- int punePort = (Integer)puneLocator.invoke(() -> WANCommandTestBase.getLocatorPort());
+ int punePort = (Integer)puneLocator.invoke(() -> getLocatorPort());
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -584,11 +587,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer)vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer)vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "receiverGroup2" ));
+ vm3.invoke(() -> createCacheWithGroups( punePort, "receiverGroup1" ));
+ vm4.invoke(() -> createCacheWithGroups( punePort, "receiverGroup1" ));
+ vm5.invoke(() -> createCacheWithGroups( punePort, "receiverGroup2" ));
String command = CliStrings.CREATE_GATEWAYRECEIVER
+ " --" + CliStrings.CREATE_GATEWAYRECEIVER__MANUALSTART + "=true"
@@ -619,11 +622,11 @@ public class WanCommandCreateGatewayReceiverDUnitTest extends WANCommandTestBase
fail("testCreateGatewayReceiver failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm3.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm4.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm4.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
- vm5.invoke(() -> WANCommandTestBase.verifyReceiverCreationWithAttributes( false, 10000,
+ vm5.invoke(() -> verifyReceiverCreationWithAttributes( false, 10000,
11000, "localhost", 100000, 512000, null ));
}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/e08fd9fd/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewaySenderDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewaySenderDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewaySenderDUnitTest.java
index d5c4b75..622abc5 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewaySenderDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandCreateGatewaySenderDUnitTest.java
@@ -16,16 +16,6 @@
*/
package com.gemstone.gemfire.internal.cache.wan.wancommand;
-import static com.gemstone.gemfire.test.dunit.Assert.*;
-import static com.gemstone.gemfire.test.dunit.LogWriterUtils.*;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Properties;
-
-import org.junit.Test;
-import org.junit.experimental.categories.Category;
-
import com.gemstone.gemfire.cache.wan.GatewaySender;
import com.gemstone.gemfire.cache.wan.GatewaySender.OrderPolicy;
import com.gemstone.gemfire.distributed.DistributedMember;
@@ -37,12 +27,25 @@ import com.gemstone.gemfire.management.internal.cli.result.CommandResult;
import com.gemstone.gemfire.management.internal.cli.result.TabularResultData;
import com.gemstone.gemfire.test.dunit.IgnoredException;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+
+import static com.gemstone.gemfire.test.dunit.Assert.*;
+import static com.gemstone.gemfire.test.dunit.LogWriterUtils.getLogWriter;
@Category(DistributedTest.class)
public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
private static final long serialVersionUID = 1L;
-
+
+ public WanCommandCreateGatewaySenderDUnitTest(boolean useHttpOnConnect, String jsonAuthorization) {
+ super(useHttpOnConnect, jsonAuthorization);
+ }
+
private CommandResult executeCommandWithIgnoredExceptions(String command) {
final IgnoredException exln = IgnoredException.addIgnoredException("Could not connect");
try {
@@ -60,7 +63,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySenderWithDefault() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -68,11 +71,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
+ CliStrings.CREATE_GATEWAYSENDER__ID + "=ln"
@@ -95,11 +98,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -109,7 +112,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySender() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -117,11 +120,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -158,18 +161,18 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm3.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, null, null ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm4.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, null, null ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm5.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, null, null ));
}
@@ -181,7 +184,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySender_Error() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -189,11 +192,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -237,7 +240,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySenderWithGatewayEventFilters() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -245,11 +248,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -288,21 +291,21 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
List<String> eventFilters = new ArrayList<String>();
eventFilters.add("com.gemstone.gemfire.cache30.MyGatewayEventFilter1");
eventFilters.add("com.gemstone.gemfire.cache30.MyGatewayEventFilter2");
- vm3.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm3.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, eventFilters, null ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm4.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, eventFilters, null ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm5.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, eventFilters, null ));
}
@@ -312,7 +315,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySenderWithGatewayTransportFilters() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() ->createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -320,11 +323,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -362,20 +365,20 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
List<String> transportFilters = new ArrayList<String>();
transportFilters.add("com.gemstone.gemfire.cache30.MyGatewayTransportFilter1");
- vm3.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm3.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, null, transportFilters ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm4.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, null, transportFilters ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm5.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, null, transportFilters ));
}
@@ -385,7 +388,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySender_OnMember() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -393,13 +396,13 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
- final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> WANCommandTestBase.getMember());
+ final DistributedMember vm3Member = (DistributedMember) vm3.invoke(() -> getMember());
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -437,10 +440,10 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm3.invoke(() -> verifySenderAttributes( "ln", 2, false, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, 2, OrderPolicy.THREAD, null, null ));
}
@@ -450,7 +453,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySender_Group() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -458,11 +461,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "SenderGroup1" ));
+ vm3.invoke(() -> createCacheWithGroups( punePort, "SenderGroup1" ));
+ vm4.invoke(() -> createCacheWithGroups( punePort, "SenderGroup1" ));
+ vm5.invoke(() -> createCacheWithGroups( punePort, "SenderGroup1" ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -500,11 +503,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -515,7 +518,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateGatewaySender_Group_Scenario2() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -523,11 +526,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "SenderGroup1" ));
- vm4.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "SenderGroup1" ));
- vm5.invoke(() -> WANCommandTestBase.createCacheWithGroups( punePort, "SenderGroup2" ));
+ vm3.invoke(() -> createCacheWithGroups( punePort, "SenderGroup1" ));
+ vm4.invoke(() -> createCacheWithGroups( punePort, "SenderGroup1" ));
+ vm5.invoke(() -> createCacheWithGroups( punePort, "SenderGroup2" ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -565,9 +568,9 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", true, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", true, false ));
}
@@ -577,7 +580,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateParallelGatewaySender() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -585,11 +588,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
props.setProperty(DistributionConfig.LOCATORS_NAME, "localhost[" + punePort + "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"
@@ -624,18 +627,18 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
fail("testCreateGatewaySender failed as did not get CommandResult");
}
- vm3.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm3.invoke(() -> verifySenderState(
"ln", false, false ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm4.invoke(() -> verifySenderState(
"ln", false, false ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderState(
+ vm5.invoke(() -> verifySenderState(
"ln", false, false ));
- vm3.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, true, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm3.invoke(() -> verifySenderAttributes( "ln", 2, true, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, GatewaySender.DEFAULT_DISPATCHER_THREADS, null, null, null ));
- vm4.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, true, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm4.invoke(() -> verifySenderAttributes( "ln", 2, true, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, GatewaySender.DEFAULT_DISPATCHER_THREADS, null, null, null ));
- vm5.invoke(() -> WANCommandTestBase.verifySenderAttributes( "ln", 2, true, true, 1000, socketReadTimeout, true, 1000, 5000,
+ vm5.invoke(() -> verifySenderAttributes( "ln", 2, true, true, 1000, socketReadTimeout, true, 1000, 5000,
true, false, 1000, 100, GatewaySender.DEFAULT_DISPATCHER_THREADS, null, null, null ));
}
@@ -646,7 +649,7 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
@Test
public void testCreateParallelGatewaySender_Error() {
- Integer punePort = (Integer) vm1.invoke(() -> WANCommandTestBase.createFirstLocatorWithDSId( 1 ));
+ Integer punePort = (Integer) vm1.invoke(() -> createFirstLocatorWithDSId( 1 ));
Properties props = getDistributedSystemProperties();
props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
@@ -655,11 +658,11 @@ public class WanCommandCreateGatewaySenderDUnitTest extends WANCommandTestBase {
+ "]");
createDefaultSetup(props);
- Integer nyPort = (Integer) vm2.invoke(() -> WANCommandTestBase.createFirstRemoteLocator( 2, punePort ));
+ Integer nyPort = (Integer) vm2.invoke(() -> createFirstRemoteLocator( 2, punePort ));
- vm3.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm4.invoke(() -> WANCommandTestBase.createCache( punePort ));
- vm5.invoke(() -> WANCommandTestBase.createCache( punePort ));
+ vm3.invoke(() -> createCache( punePort ));
+ vm4.invoke(() -> createCache( punePort ));
+ vm5.invoke(() -> createCache( punePort ));
int socketReadTimeout = GatewaySender.MINIMUM_SOCKET_READ_TIMEOUT+1000;
String command = CliStrings.CREATE_GATEWAYSENDER + " --"