Merge pull request #42503 from izeye

* pr/42503:
  Polish

Closes gh-42503

spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/tracing/OpenTelemetryEventPublisherBeansApplicationListener.java

@@ -99,8 +99,8 @@ public class OpenTelemetryEventPublisherBeansApplicationListener implements Gene
 
 	/**
 	 * {@link ContextStorage#addWrapper(java.util.function.Function) Add} the
-	 * {@link ContextStorage} wrapper to ensure that {@link EventPublisher} are propagated
-	 * correctly.
+	 * {@link ContextStorage} wrapper to ensure that {@link EventPublisher
+	 * EventPublishers} are propagated correctly.
 	 */
 	public static void addWrapper() {
 		if (isInstallable() && added.compareAndSet(false, true)) {
@@ -118,7 +118,7 @@ public class OpenTelemetryEventPublisherBeansApplicationListener implements Gene
 	 */
 	static final class Wrapper {
 
-		static Wrapper instance = new Wrapper();
+		static final Wrapper instance = new Wrapper();
 
 		private final MultiValueMap<ApplicationContext, EventPublishingContextWrapper> beans = new LinkedMultiValueMap<>();
 
@@ -149,13 +149,16 @@ public class OpenTelemetryEventPublisherBeansApplicationListener implements Gene
 			ContextStorage delegate = this.storageDelegate;
 			if (delegate == null) {
 				synchronized (this) {
-					delegate = parent;
-					for (List<EventPublishingContextWrapper> publishers : this.beans.values()) {
-						for (EventPublishingContextWrapper publisher : publishers) {
-							delegate = publisher.apply(delegate);
+					delegate = this.storageDelegate;
+					if (delegate == null) {
+						delegate = parent;
+						for (List<EventPublishingContextWrapper> publishers : this.beans.values()) {
+							for (EventPublishingContextWrapper publisher : publishers) {
+								delegate = publisher.apply(delegate);
+							}
 						}
+						this.storageDelegate = delegate;
 					}
-					this.storageDelegate = delegate;
 				}
 			}
 			return delegate;

spring-boot-project/spring-boot-actuator-autoconfigure/src/test/java/org/springframework/boot/actuate/autoconfigure/tracing/BaggagePropagationIntegrationTests.java

@@ -57,7 +57,6 @@ class BaggagePropagationIntegrationTests {
 	@BeforeEach
 	@AfterEach
 	void setup() {
-		OpenTelemetryEventPublisherBeansApplicationListener.addWrapper();
 		MDC.clear();
 	}
 

spring-boot-project/spring-boot-test-autoconfigure/src/dockerTest/java/org/springframework/boot/test/autoconfigure/data/ldap/DataLdapTestDockerTests.java

@@ -58,8 +58,7 @@ class DataLdapTestDockerTests {
 	void connectionCanBeMadeToLdapContainer() {
 		List<String> cn = this.ldapTemplate.search(LdapQueryBuilder.query().where("objectclass").is("dcObject"),
 				(AttributesMapper<String>) (attributes) -> attributes.get("dc").get().toString());
-		assertThat(cn).hasSize(1);
-		assertThat(cn.get(0)).isEqualTo("example");
+		assertThat(cn).singleElement().isEqualTo("example");
 	}
 
 	@Test

spring-boot-project/spring-boot-testcontainers/src/dockerTest/java/org/springframework/boot/testcontainers/service/connection/ldap/OpenLdapContainerConnectionDetailsFactoryIntegrationTests.java

@@ -56,8 +56,7 @@ class OpenLdapContainerConnectionDetailsFactoryIntegrationTests {
 	void connectionCanBeMadeToLdapContainer() {
 		List<String> cn = this.ldapTemplate.search(LdapQueryBuilder.query().where("objectclass").is("dcObject"),
 				(AttributesMapper<String>) (attributes) -> attributes.get("dc").get().toString());
-		assertThat(cn).hasSize(1);
-		assertThat(cn.get(0)).isEqualTo("example");
+		assertThat(cn).singleElement().isEqualTo("example");
 	}
 
 	@Configuration(proxyBeanMethods = false)

spring-boot-project/spring-boot-testcontainers/src/main/java/org/springframework/boot/testcontainers/service/connection/ContainerConnectionDetailsFactory.java

@@ -117,7 +117,7 @@ public abstract class ContainerConnectionDetailsFactory<C extends Container<?>,
 	}
 
 	/**
-	 * Return if the give source accepts the connection. By default this method checks
+	 * Return if the given source accepts the connection. By default this method checks
 	 * each connection name.
 	 * @param source the container connection source
 	 * @param requiredContainerType the required container type

spring-boot-project/spring-boot-testcontainers/src/main/java/org/springframework/boot/testcontainers/service/connection/ContainerConnectionSource.java

@@ -95,7 +95,7 @@ public final class ContainerConnectionSource<C extends Container<?>> implements
 	}
 
 	/**
-	 * Return is this source accepts the given connection.
+	 * Return if this source accepts the given connection.
 	 * @param requiredConnectionName the required connection name or {@code null}
 	 * @param requiredContainerType the required container type
 	 * @param requiredConnectionDetailsType the required connection details type