dash

Signed-off-by: appleboy <[email protected]>

Author: appleboy

rabbitmq_test.go

@@ -36,8 +36,7 @@ func setupRabbitMQContainer(ctx context.Context, t *testing.T) (testcontainers.C
 	req := testcontainers.ContainerRequest{
 		Image: "rabbitmq:3-management",
 		ExposedPorts: []string{
-			"5672/tcp",  // amqp
-			"15672/tcp", // management plugin
+			"5672/tcp", // amqp
 		},
 		WaitingFor: wait.ForListeningPort("5672/tcp"),
 		Env: map[string]string{
@@ -61,7 +60,7 @@ func TestShutdownWorkFlow(t *testing.T) {
 	ctx := context.Background()
 	natsC, endpoint := setupRabbitMQContainer(ctx, t)
 	defer testcontainers.CleanupContainer(t, natsC)
-	log.Println(endpoint)
+	log.Println("RabbitMQ endpoint:", endpoint)
 	w := NewWorker(
 		WithQueue("test"),
 		WithAddr(fmt.Sprintf("amqp://guest:guest@%s/", endpoint)),