No Task - Added JUnit assume so that tests run on multiple hosts only.

Author: georgeajit

marklogic-client-api-functionaltests/src/test/java/com/marklogic/client/datamovement/functionaltests/QBFailover.java

@@ -36,6 +36,7 @@
 import org.junit.After;
 import org.junit.AfterClass;
 import org.junit.Assert;
+import org.junit.Assume;
 import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
@@ -282,6 +283,8 @@ public void tearDown() throws Exception {
 
 	@Test(timeout = 450000)
 	public void testStopOneNode() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
 		AtomicInteger failure = new AtomicInteger(0);
@@ -317,6 +320,8 @@ public void testStopOneNode() throws Exception {
 
 	@Test(timeout = 450000)
 	public void testRestart() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
 		AtomicInteger failure = new AtomicInteger(0);
@@ -354,6 +359,8 @@ public void testRestart() throws Exception {
 
 	@Test(timeout = 450000)
 	public void testRepeatedStopOneNode() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
 		AtomicInteger failure = new AtomicInteger(0);
@@ -398,6 +405,8 @@ public void testRepeatedStopOneNode() throws Exception {
 
 	@Test(timeout = 450000)
 	public void testMinNodes() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicInteger success = new AtomicInteger(0);
 		AtomicInteger failure = new AtomicInteger(0);
@@ -442,6 +451,8 @@ public void testMinNodes() throws Exception {
 
 	@Test(timeout = 450000)
 	public void testStopTwoNodes() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {
 			final AtomicInteger success = new AtomicInteger(0);
@@ -485,6 +496,8 @@ public void testStopTwoNodes() throws Exception {
 
 	@Test(timeout = 450000)
 	public void xQueryMasstransformReplace() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
 		transform.put("name", "Lang");
@@ -555,6 +568,8 @@ public void xQueryMasstransformReplace() throws Exception {
 
 	@Test(timeout = 450000)
 	public void xQueryMasstransformReplaceTwoNodes() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
 		transform.put("name", "Lang");
@@ -627,6 +642,8 @@ public void xQueryMasstransformReplaceTwoNodes() throws Exception {
 
 	@Test(timeout = 450000)
 	public void xQueryMasstransformReplaceRepeated() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		ServerTransform transform = new ServerTransform("add-attr-xquery-transform");
 		transform.put("name", "Lang");
@@ -705,6 +722,8 @@ public void xQueryMasstransformReplaceRepeated() throws Exception {
 
 	@Test(timeout = 450000)
 	public void massDeleteConsistentSnapShot() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		AtomicBoolean isRunning = new AtomicBoolean(true);
 		Map<String, String> props = new HashMap<String, String>();

marklogic-client-api-functionaltests/src/test/java/com/marklogic/client/datamovement/functionaltests/WBFailover.java

@@ -32,6 +32,7 @@
 import org.junit.After;
 import org.junit.AfterClass;
 import org.junit.Assert;
+import org.junit.Assume;
 import org.junit.Before;
 import org.junit.BeforeClass;
 import org.junit.Test;
@@ -242,6 +243,8 @@ public void tearDown() throws Exception {
 
 	@Test(timeout = 350000)
 	public void testBlackListHost() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		try {
 			System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 			final AtomicInteger successCount = new AtomicInteger(0);
@@ -287,6 +290,8 @@ public void testBlackListHost() throws Exception {
 
 	@Test(timeout = 350000)
 	public void testStopOneNode() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		Assert.assertTrue(evalClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 0);
 		final AtomicInteger successCount = new AtomicInteger(0);
@@ -332,6 +337,8 @@ public void testStopOneNode() throws Exception {
 
 	@Test(timeout = 350000)
 	public void testRestart() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		Assert.assertTrue(evalClient.newServerEval().xquery(query1).eval().next().getNumber().intValue() == 0);
 		final AtomicInteger successCount = new AtomicInteger(0);
@@ -380,6 +387,8 @@ public void testRestart() throws Exception {
 
 	@Test(timeout = 350000)
 	public void testRepeatedStopOneNode() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {
 			final AtomicInteger successCount = new AtomicInteger(0);
@@ -437,6 +446,8 @@ public void testRepeatedStopOneNode() throws Exception {
 
 	@Test(timeout = 350000)
 	public void testStopTwoNodes() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {
 			final AtomicInteger successCount = new AtomicInteger(0);
@@ -496,6 +507,8 @@ public void testStopTwoNodes() throws Exception {
 
 	@Test(timeout = 350000)
 	public void testMinHosts() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		final AtomicInteger successCount = new AtomicInteger(0);
 		final AtomicInteger failCount = new AtomicInteger(0);
@@ -539,6 +552,8 @@ public void testMinHosts() throws Exception {
 
 	@Test(timeout = 350000)
 	public void testWhiteBlackListNPE() throws Exception {
+		Assume.assumeTrue(hostNames.length > 1);
+		
 		System.out.println(Thread.currentThread().getStackTrace()[1].getMethodName());
 		try {
 			FilteredForestConfiguration forestConfig = new FilteredForestConfiguration(dmManager.readForestConfig())