fix(modules/rabbitmq): update container image to 3.12.11 to allow con…

…nections without passing admin credentials (#2051) * chore(modules/rabbitmq): update container image to 3.12.11 * test: update image tag & add test with default options
testcontainers · Jan 12, 2024 · 7b06a62 · 7b06a62
1 parent 669d6f8
commit 7b06a62
Show file tree

Hide file tree

Showing 3 changed files with 34 additions and 3 deletions.
diff --git a/modules/rabbitmq/examples_test.go b/modules/rabbitmq/examples_test.go
@@ -18,7 +18,7 @@ func ExampleRunContainer() {
 	ctx := context.Background()
 
 	rabbitmqContainer, err := rabbitmq.RunContainer(ctx,
-		testcontainers.WithImage("rabbitmq:3.7.25-management-alpine"),
+		testcontainers.WithImage("rabbitmq:3.12.11-management-alpine"),
 		rabbitmq.WithAdminUsername("admin"),
 		rabbitmq.WithAdminPassword("password"),
 	)

diff --git a/modules/rabbitmq/rabbitmq.go b/modules/rabbitmq/rabbitmq.go
@@ -69,7 +69,7 @@ func (c *RabbitMQContainer) HttpsURL(ctx context.Context) (string, error) {
 // RunContainer creates an instance of the RabbitMQ container type
 func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomizer) (*RabbitMQContainer, error) {
 	req := testcontainers.ContainerRequest{
-		Image: "rabbitmq:3.7.25-management-alpine",
+		Image: "rabbitmq:3.12.11-management-alpine",
 		Env: map[string]string{
 			"RABBITMQ_DEFAULT_USER": defaultUser,
 			"RABBITMQ_DEFAULT_PASS": defaultPassword,

diff --git a/modules/rabbitmq/rabbitmq_test.go b/modules/rabbitmq/rabbitmq_test.go
@@ -7,15 +7,46 @@ import (
 	"strings"
 	"testing"
 
+	amqp "github.com/rabbitmq/amqp091-go"
+
 	"github.com/testcontainers/testcontainers-go"
 	"github.com/testcontainers/testcontainers-go/modules/rabbitmq"
 )
 
+func TestRunContainer_connectUsingAmqp(t *testing.T) {
+	ctx := context.Background()
+
+	rabbitmqContainer, err := rabbitmq.RunContainer(ctx)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	defer func() {
+		if err := rabbitmqContainer.Terminate(ctx); err != nil {
+			t.Fatal(err)
+		}
+	}()
+
+	amqpURL, err := rabbitmqContainer.AmqpURL(ctx)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	amqpConnection, err := amqp.Dial(amqpURL)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if err = amqpConnection.Close(); err != nil {
+		t.Fatal(err)
+	}
+}
+
 func TestRunContainer_withAllSettings(t *testing.T) {
 	ctx := context.Background()
 
 	rabbitmqContainer, err := rabbitmq.RunContainer(ctx,
-		testcontainers.WithImage("rabbitmq:3.7.25-management-alpine"),
+		testcontainers.WithImage("rabbitmq:3.12.11-management-alpine"),
 		// addVirtualHosts {
 		testcontainers.WithStartupCommand(VirtualHost{Name: "vhost1"}),
 		testcontainers.WithStartupCommand(VirtualHostLimit{VHost: "vhost1", Name: "max-connections", Value: 1}),