Fix comments

Author: eddumelendez

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitStreamConfiguration.java

@@ -113,12 +113,18 @@ static EnvironmentBuilder configure(EnvironmentBuilder builder, RabbitProperties
 		PropertyMapper map = PropertyMapper.get();
 		map.from(connectionDetails.getHost()).to(builder::host);
 		map.from(connectionDetails.getPort()).to(builder::port);
-		map.from(stream.getVirtualHost())
+		map.from(connectionDetails.getVirtualHost())
 			.as(withFallback(properties::getVirtualHost))
 			.whenNonNull()
 			.to(builder::virtualHost);
-		map.from(stream.getUsername()).as(withFallback(properties::getUsername)).whenNonNull().to(builder::username);
-		map.from(stream.getPassword()).as(withFallback(properties::getPassword)).whenNonNull().to(builder::password);
+		map.from(connectionDetails.getUsername())
+			.as(withFallback(properties::getUsername))
+			.whenNonNull()
+			.to(builder::username);
+		map.from(connectionDetails.getPassword())
+			.as(withFallback(properties::getPassword))
+			.whenNonNull()
+			.to(builder::password);
 		return builder;
 	}
 
@@ -144,6 +150,21 @@ public int getPort() {
 			return this.streamProperties.getPort();
 		}
 
+		@Override
+		public String getVirtualHost() {
+			return this.streamProperties.getVirtualHost();
+		}
+
+		@Override
+		public String getUsername() {
+			return this.streamProperties.getUsername();
+		}
+
+		@Override
+		public String getPassword() {
+			return this.streamProperties.getPassword();
+		}
+
 	}
 
 }

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitStreamConnectionDetails.java

@@ -38,4 +38,28 @@ public interface RabbitStreamConnectionDetails extends ConnectionDetails {
 	 */
 	int getPort();
 
+	/**
+	 * Login user to authenticate to the broker.
+	 * @return the login user to authenticate to the broker or {@code null}
+	 */
+	default String getUsername() {
+		return null;
+	}
+
+	/**
+	 * Login to authenticate against the broker.
+	 * @return the login to authenticate against the broker or {@code null}
+	 */
+	default String getPassword() {
+		return null;
+	}
+
+	/**
+	 * Virtual host to use when connecting to the broker.
+	 * @return the virtual host to use when connecting to the broker or {@code null}
+	 */
+	default String getVirtualHost() {
+		return null;
+	}
+
 }

spring-boot-project/spring-boot-testcontainers/src/dockerTest/java/org/springframework/boot/testcontainers/service/connection/amqp/RabbitStreamContainerConnectionDetailsFactoryIntegrationTests.java

@@ -66,7 +66,7 @@ class RabbitStreamContainerConnectionDetailsFactoryIntegrationTests {
 	private static RabbitMQContainer getRabbitMqStreamContainer() {
 		RabbitMQContainer container = TestImage.container(RabbitMQContainer.class);
 		container.addExposedPorts(RABBITMQ_STREAMS_PORT);
-		var enabledPlugins = "[rabbitmq_stream,rabbitmq_prometheus].";
+		String enabledPlugins = "[rabbitmq_stream,rabbitmq_prometheus].";
 		container.withCopyToContainer(Transferable.of(enabledPlugins), "/etc/rabbitmq/enabled_plugins");
 		return container;
 	}

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

@@ -64,6 +64,16 @@ public int getPort() {
 			return getContainer().getMappedPort(5552);
 		}
 
+		@Override
+		public String getUsername() {
+			return getContainer().getAdminUsername();
+		}
+
+		@Override
+		public String getPassword() {
+			return getContainer().getAdminPassword();
+		}
+
 	}
 
 }