17
17
import io .strimzi .test .k8s .KubeClusterResource ;
18
18
import org .apache .logging .log4j .LogManager ;
19
19
import org .apache .logging .log4j .Logger ;
20
+ import org .apache .logging .log4j .ThreadContext ;
20
21
import org .junit .jupiter .api .AfterAll ;
21
22
import org .junit .jupiter .api .AfterEach ;
22
23
import org .junit .jupiter .api .BeforeAll ;
@@ -138,6 +139,14 @@ protected void beforeAllMayOverride() {
138
139
139
140
@ BeforeEach
140
141
void setUpTestCase (ExtensionContext extensionContext ) {
142
+ // Check if we execute tests in parallel to update logger appender dynamically
143
+ boolean parallelEnabled = Boolean .getBoolean ("junit.jupiter.execution.parallel.enabled" );
144
+ if (extensionContext .getTestClass ().isPresent () && parallelEnabled ) {
145
+ ThreadContext .put ("testClass" , extensionContext .getTestClass ().get ().getSimpleName ());
146
+ }
147
+ if (extensionContext .getTestMethod ().isPresent () && parallelEnabled ) {
148
+ ThreadContext .put ("testMethod" , extensionContext .getTestMethod ().get ().getName ());
149
+ }
141
150
ResourceManager .setTestContext (extensionContext );
142
151
LOGGER .debug (String .join ("" , Collections .nCopies (76 , "=" )));
143
152
LOGGER .debug ("———————————— {}@Before Each - Setup TestCase environment ———————————— " , StUtils .removePackageName (this .getClass ().getName ()));
@@ -147,6 +156,11 @@ void setUpTestCase(ExtensionContext extensionContext) {
147
156
148
157
@ BeforeAll
149
158
void setUpTestSuite (ExtensionContext extensionContext ) {
159
+ // Check if we execute tests in parallel to update logger appender dynamically
160
+ boolean parallelEnabled = Boolean .getBoolean ("junit.jupiter.execution.parallel.enabled" );
161
+ if (extensionContext .getTestClass ().isPresent () && parallelEnabled ) {
162
+ ThreadContext .put ("testClass" , extensionContext .getTestClass ().get ().getSimpleName ());
163
+ }
150
164
ResourceManager .setTestContext (extensionContext );
151
165
LOGGER .debug (String .join ("" , Collections .nCopies (76 , "=" )));
152
166
LOGGER .debug ("———————————— {}@Before All - Setup TestSuite environment ———————————— " , StUtils .removePackageName (this .getClass ().getName ()));
@@ -170,6 +184,7 @@ void tearDownTestCase(ExtensionContext extensionContext) throws Exception {
170
184
} finally {
171
185
afterEachMayOverride ();
172
186
afterEachMustExecute ();
187
+ ThreadContext .remove ("testMethod" );
173
188
}
174
189
}
175
190
@@ -180,5 +195,6 @@ void tearDownTestSuite(ExtensionContext extensionContext) {
180
195
LOGGER .debug ("———————————— {}@After All - Clean up after TestSuite ———————————— " , StUtils .removePackageName (this .getClass ().getName ()));
181
196
afterAllMayOverride ();
182
197
afterAllMustExecute ();
198
+ ThreadContext .remove ("testClass" );
183
199
}
184
200
}
0 commit comments