SimpleMessageListenerContainer - Broker not available; cannot force queue declarations during start: java.io.IOException

[AndrejsZavjalovs]

Hello, after star local app, testcontainer up rabbitmq, but can't connect from spring boot app.
I can connect without any problem through browser: http://localhost:15672/

spring-boot-starter-amqp: 2.7.1
org.testcontainers:rabbitmq: 1.17.2

Log:

17:04:40.622 [main] INFO  🐳 [rabbitmq:3.8-management-alpine] - Container rabbitmq:3.8-management-alpine started in PT21.17164S
17:04:41.459 [main] INFO  o.s.b.w.e.tomcat.TomcatWebServer - Tomcat started on port(s): 8097 (http) with context path ''
17:04:41.651 [main] INFO  o.s.b.w.e.tomcat.TomcatWebServer - Tomcat initialized with port(s): 8103 (http)
17:04:41.658 [main] INFO  o.a.catalina.core.StandardService - Starting service [Tomcat]
17:04:41.658 [main] INFO  o.a.catalina.core.StandardEngine - Starting Servlet engine: [Apache Tomcat/9.0.63]
17:04:41.698 [main] INFO  o.a.c.c.C.[Tomcat-1].[localhost].[/] - Initializing Spring embedded WebApplicationContext
17:04:41.698 [main] INFO  o.s.b.w.s.c.ServletWebServerApplicationContext - Root WebApplicationContext: initialization completed in 235 ms
17:04:41.726 [main] INFO  o.s.b.a.e.web.EndpointLinksResolver - Exposing 1 endpoint(s) beneath base path '/actuator'
17:04:41.779 [main] INFO  o.s.b.w.e.tomcat.TomcatWebServer - Tomcat started on port(s): 8103 (http) with context path ''
17:04:41.784 [main] INFO  o.s.a.r.c.CachingConnectionFactory - Attempting to connect to: localhost:15672
17:04:46.801 [AMQP Connection 127.0.0.1:15672] WARN  c.r.c.impl.ForgivingExceptionHandler - An unexpected connection driver error occurred (Exception message: Socket closed)
17:04:51.803 [main] INFO  o.s.a.r.l.SimpleMessageListenerContainer - Broker not available; cannot force queue declarations during start: java.io.IOException
17:04:51.810 [request-listener-1] INFO  o.s.a.r.c.CachingConnectionFactory - Attempting to connect to: localhost:15672
17:05:01.810 [request-listener-1] ERROR o.s.a.r.l.SimpleMessageListenerContainer - Failed to check/redeclare auto-delete queue(s).
org.springframework.amqp.AmqpIOException: java.io.IOException
	at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:70)
	at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:602)
	at org.springframework.amqp.rabbit.connection.CachingConnectionFactory.createConnection(CachingConnectionFactory.java:725)
	at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.createConnection(ConnectionFactoryUtils.java:252)
	at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:2173)
	at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:2146)
	at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:2126)
	at org.springframework.amqp.rabbit.core.RabbitAdmin.getQueueInfo(RabbitAdmin.java:463)
	at org.springframework.amqp.rabbit.core.RabbitAdmin.getQueueProperties(RabbitAdmin.java:447)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.attemptDeclarations(AbstractMessageListenerContainer.java:1917)
	at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.redeclareElementsIfNecessary(AbstractMessageListenerContainer.java:1898)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.initialize(SimpleMessageListenerContainer.java:1374)
	at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1220)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: java.io.IOException: null
	at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129)
	at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125)
	at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:396)
	at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1225)
	at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1173)
	at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1342)
	at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.connectHostPort(AbstractConnectionFactory.java:653)
	at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.connect(AbstractConnectionFactory.java:618)
	at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:565)
	... 12 common frames omitted
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error
	at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66)
	at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36)
	at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:502)
	at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:326)
	... 18 common frames omitted
Caused by: java.io.EOFException: null
	at java.base/java.io.DataInputStream.readUnsignedByte(DataInputStream.java:295)
	at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:91)
	at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:184)
	at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:665)
	... 1 common frames omitted
17:05:01.811 [request-listener-1] INFO  o.s.a.r.c.CachingConnectionFactory - Attempting to connect to: localhost:15672
17:05:11.821 [main] INFO  c.m.a.LocalAttestationApplication - Started LocalAttestationApplication in 64.36 seconds (JVM running for 65.024)

[artembilan]

17:04:41.784 [main] INFO  o.s.a.r.c.CachingConnectionFactory - Attempting to connect to: localhost:15672

The port is not correct. Must be 5672. The one you use is for management plugin over HTTP.
The CachingConnectionFactory have to connect to the AMQP port: https://www.rabbitmq.com/networking.html

[AndrejsZavjalovs]

GenericContainer rabbitMQContainer =
    new GenericContainer(DockerImageName.parse("rabbitmq:" + version))
        .withEnv("RABBITMQ_DEFAULT_USER", username)
        .withEnv("RABBITMQ_DEFAULT_PASS", password)
        .withEnv("RABBITMQ_DEFAULT_VHOST", vhost)
        .withExposedPorts(5672, 15672)
        .waitingFor(Wait.forListeningPort());
rabbitMQContainer.setPortBindings(List.of(5672 + ":" + 5672));
rabbitMQContainer.setPortBindings(List.of(15672 + ":" + 15672));

does not connect to any of the ports, the local container is running and working fine

[AndrejsZavjalovs]

working configuration:

GenericContainer rabbitMQContainer =
new GenericContainer(DockerImageName.parse("rabbitmq:" + version))
.withEnv("RABBITMQ_DEFAULT_USER", username)
.withEnv("RABBITMQ_DEFAULT_PASS", password)
.withEnv("RABBITMQ_DEFAULT_VHOST", vhost)
.withEnv("RABBITMQ_PORT", String.valueOf(port))
.withEnv("RABBITMQ_HOST", host)
.withExposedPorts(5672)
.withExposedPorts(15672)
.waitingFor(Wait.forListeningPort());rabbitMQContainer.setPortBindings(List.of(5672 + ":" + 5672))