Add RabbitStreamConnectionDetails and support from RabbitMQContainer
when rabbitmq_stream plugin is enabled.
Comment From: eddumelendez
rabbitmq_stream plugin uses a new port 5552. If the plugin is not enabled, then it will fail because can not get the mapped port. This also requires an additional bean, otherwise will fail. See https://www.rabbitmq.com/blog/2021/07/23/connecting-to-streams#using-the-stream-java-client-with-a-load-balancer
@Bean
EnvironmentBuilderCustomizer environmentBuilderCustomizer() {
return env -> {
Address entrypoint = new Address(rabbit.getHost(), rabbit.getMappedPort(RABBITMQ_STREAMS_PORT));
env.addressResolver(address -> entrypoint);
};
}
Comment From: eddumelendez
PR has been updated