feat: #89 Adding AMQP/RabbitMQ support for mocking async messages

Signed-off-by: Laurent Broudoux <laurent.broudoux@gmail.com>

Author: lbroudoux

ensemble/async/async.go

@@ -137,7 +137,7 @@ func WithKafkaConnection(connection kafka.Connection) testcontainers.CustomizeRe
 	}
 }
 
-// WithKafkaConnection connects the MicrocksAsyncMinionContainer to a MQTT broker to allow MQTT messages mocking.
+// WithMQTTConnection connects the MicrocksAsyncMinionContainer to a MQTT broker to allow MQTT messages mocking.
 func WithMQTTConnection(connection generic.Connection) testcontainers.CustomizeRequestOption {
 	return func(req *testcontainers.GenericContainerRequest) error {
 		if req.Env == nil {
@@ -152,6 +152,21 @@ func WithMQTTConnection(connection generic.Connection) testcontainers.CustomizeR
 	}
 }
 
+// WithAMQPConnection connects the MicrocksAsyncMinionContainer to an AMQP/RabbitMQ broker to allow MQTT messages mocking.
+func WithAMQPConnection(connection generic.Connection) testcontainers.CustomizeRequestOption {
+	return func(req *testcontainers.GenericContainerRequest) error {
+		if req.Env == nil {
+			req.Env = make(map[string]string)
+		}
+		req.Env["AMQP_SERVER"] = connection.Server
+		req.Env["AMQP_USERNAME"] = connection.Username
+		req.Env["AMQP_PASSWORD"] = connection.Password
+		addProtocol(req, "AMQP")
+
+		return nil
+	}
+}
+
 // WSMockEndpoint gets the exposed mock endpoints for a WebSocket Service.
 func (container *MicrocksAsyncMinionContainer) WSMockEndpoint(ctx context.Context, service, version, operationName string) (string, error) {
 	// Get the container host.

ensemble/ensemble.go

@@ -293,6 +293,14 @@ func WithMQTTConnection(connection generic.Connection) Option {
 	}
 }
 
+// WithAMQPConnection configures a connection to an AMQP/RabbitMQ Broker.
+func WithAMQPConnection(connection generic.Connection) Option {
+	return func(e *MicrocksContainersEnsemble) error {
+		e.asyncMinionContainerOptions.Add(async.WithAMQPConnection(connection))
+		return nil
+	}
+}
+
 // WithSecret creates a new secret.
 func WithSecret(s client.Secret) Option {
 	return func(e *MicrocksContainersEnsemble) error {