chore: update RabbitMQ container setup and logging in tests

- Add `4369/tcp` port for epmd in RabbitMQ container setup
- Remove `15672/tcp` port for the management plugin in RabbitMQ container setup
- Rename `natsC` to `rabbitMQC` in `TestShutdownWorkFlow`
- Update log message to include "RabbitMQ endpoint:" in `TestShutdownWorkFlow`

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

Author: appleboy

rabbitmq_test.go

@@ -36,8 +36,8 @@ 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
+			"4369/tcp", // epmd
+			"5672/tcp", // amqp
 		},
 		WaitingFor: wait.ForListeningPort("5672/tcp"),
 		Env: map[string]string{
@@ -59,9 +59,9 @@ func setupRabbitMQContainer(ctx context.Context, t *testing.T) (testcontainers.C
 
 func TestShutdownWorkFlow(t *testing.T) {
 	ctx := context.Background()
-	natsC, endpoint := setupRabbitMQContainer(ctx, t)
-	defer testcontainers.CleanupContainer(t, natsC)
-	log.Println(endpoint)
+	rabbitMQC, endpoint := setupRabbitMQContainer(ctx, t)
+	defer testcontainers.CleanupContainer(t, rabbitMQC)
+	log.Println("RabbitMQ endpoint:", endpoint)
 	w := NewWorker(
 		WithQueue("test"),
 		WithAddr(fmt.Sprintf("amqp://guest:guest@%s/", endpoint)),