1 package org.apache.maven.surefire.junitcore;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.util.Map;
23
24 import org.apache.maven.surefire.api.report.ConsoleStream;
25 import org.apache.maven.surefire.api.report.ReporterFactory;
26 import org.apache.maven.surefire.api.testset.TestSetFailedException;
27 import org.junit.runner.notification.RunListener.ThreadSafe;
28
29
30
31
32 @ThreadSafe
33 public class ClassesParallelRunListener
34 extends ConcurrentRunListener
35 {
36 public ClassesParallelRunListener( Map<String, TestSet> classMethodCounts, ReporterFactory reporterFactory,
37 ConsoleStream consoleStream )
38 throws TestSetFailedException
39 {
40 super( reporterFactory, consoleStream, false, classMethodCounts );
41 }
42
43 @Override
44 protected void checkIfTestSetCanBeReported( TestSet testSetForTest )
45 {
46 TestSet currentlyAttached = TestSet.getThreadTestSet();
47 if ( currentlyAttached != null && currentlyAttached != testSetForTest )
48 {
49 currentlyAttached.setAllScheduled( getRunListener() );
50 }
51 }
52 }