Struct testcontainers_modules::rabbitmq::RabbitMq

pub struct RabbitMq;

Available on crate feature rabbitmq only.

Module to work with RabbitMQ inside of tests.

Starts an instance of RabbitMQ with the management-plugin started by default, so you are able to use the RabbitMQ Management HTTP API to manage the configuration if the started RabbitMQ instance at test runtime.

This module is based on the official RabbitMQ docker image.

Example

use testcontainers_modules::{rabbitmq, testcontainers::runners::SyncRunner};

let rabbitmq_instance = rabbitmq::RabbitMq.start();

let amqp_url = format!("amqp://{}:{}", rabbitmq_instance.get_host_ip_address(), rabbitmq_instance.get_host_port_ipv4(5672));

// do something with the started rabbitmq instance..

Trait Implementations

impl Clone for RabbitMq

fn clone(&self) -> RabbitMq

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RabbitMq

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RabbitMq

fn default() -> RabbitMq

Returns the “default value” for a type.

impl Image for RabbitMq

type Args = ()

A type representing the arguments for an Image.

fn name(&self) -> String

The name of the docker image to pull from the Docker Hub registry.

fn tag(&self) -> String

Implementations are encouraged to include a tag that will not change (i.e. NOT latest) in order to prevent test code from randomly breaking because the underlying docker suddenly changed.

fn ready_conditions(&self) -> Vec<WaitFor>

Returns a list of conditions that need to be met before a started container is considered ready.

fn env_vars(&self) -> Box<dyn Iterator<Item = (&String, &String)> + '_>

There are a couple of things regarding the environment variables of images:

fn mounts(&self) -> Box<dyn Iterator<Item = &Mount> + '_>

There are a couple of things regarding the mounts of images:

fn entrypoint(&self) -> Option<String>

Returns the entrypoint this instance was created with.

fn expose_ports(&self) -> Vec<u16>

Returns the ports that needs to be exposed when a container is created.

fn exec_after_start(&self, cs: ContainerState) -> Vec<ExecCommand>

Returns the commands that needs to be executed after a container is started i.e. commands to be run in a running container.