Sample client rabbitmq with test containers

testcontainers_RabbitMQClient.java

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
import org.testcontainers.containers.RabbitMQContainer;

public class RabbitMQClient {

  public static void sendMessage(final RabbitMQContainer rabbitMQContainer, final String queue,
      final byte[] message) throws IOException, TimeoutException {
    try (Connection connection = getConnection(rabbitMQContainer)) {
      try (Channel channel = connection.createChannel()) {
        channel.basicPublish("", queue, null, message);
      }
    }
  }

  public static void purgeQueue(final RabbitMQContainer rabbitMQContainer, final String queue)
      throws IOException, TimeoutException {
    try (Connection connection = getConnection(rabbitMQContainer)) {
      try (Channel channel = connection.createChannel()) {
        channel.queuePurge(queue);
      }
    }
  }

  private static Connection getConnection(final RabbitMQContainer rabbitMQContainer)
      throws IOException, TimeoutException {
    final var factory = new ConnectionFactory();
    factory.setHost(rabbitMQContainer.getHost());
    factory.setPort(rabbitMQContainer.getMappedPort(5672));
    factory.setUsername(rabbitMQContainer.getAdminUsername());
    factory.setPassword(rabbitMQContainer.getAdminPassword());
    return factory.newConnection();
  }

}