We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e6b5e17 commit 5d8e1c1Copy full SHA for 5d8e1c1
rabbitmq_test.go
@@ -34,12 +34,12 @@ func (m mockMessage) Bytes() []byte {
34
35
func setupRabbitMQContainer(ctx context.Context, t *testing.T) (testcontainers.Container, string) {
36
req := testcontainers.ContainerRequest{
37
- Image: "rabbitmq:3",
+ Image: "rabbitmq:3-management",
38
ExposedPorts: []string{
39
"5672/tcp", // amqp
40
"15672/tcp", // management plugin
41
},
42
- WaitingFor: wait.ForLog("TCP: listening on"),
+ WaitingFor: wait.ForListeningPort("5672/tcp"),
43
Env: map[string]string{
44
"RABBITMQ_DEFAULT_USER": "guest",
45
"RABBITMQ_DEFAULT_PASS": "guest",
0 commit comments