Introduce FailureDetector

src/test/java/testngparallel/FailureDetector.java

@@ -0,0 +1,20 @@
+package testngparallel;
+
+import org.testng.*;
+
+public class FailureDetector implements IConfigurationListener, IDataProviderListener {
+	public static final String FAILURE = "failure";
+
+	@Override
+	public void onConfigurationFailure(ITestResult itr) {
+		itr.getTestContext().setAttribute(FAILURE, Boolean.TRUE.toString());
+	}
+
+	@Override
+	public void beforeDataProviderExecution(IDataProviderMethod dataProviderMethod, ITestNGMethod method, ITestContext iTestContext) {
+		if (iTestContext.getAttribute(FailureDetector.FAILURE) != null) {
+			throw new SkipException("Failure");
+		}
+	}
+}
+

src/test/java/testngparallel/MasterTestClass.java

@@ -11,8 +11,7 @@
 import testngparallel.listeners.TestReporter;
 
 import java.lang.invoke.MethodHandles;
-
-@Listeners({MasterTestClass.class, TestReporter.class})
+@Listeners({MasterTestClass.class, TestReporter.class, FailureDetector.class})
 public class MasterTestClass implements ITestListener, ISuiteListener {
 	private static final Logger logger = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());