cilerler/rabbitmq repository overview

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

services:
  rabbitmq:
    image: cilerler/rabbitmq:4.2.1-management-delayed
    command: >
      bash -c "rabbitmq-plugins enable rabbitmq_delayed_message_exchange && rabbitmq-server"

channel.ExchangeDeclare(
    exchange: "my-delayed-exchange",
    type: "x-delayed-message",
    durable: true,
    arguments: new Dictionary<string, object>
    {
        { "x-delayed-type", "direct" }
    });

var properties = channel.CreateBasicProperties();
properties.Headers = new Dictionary<string, object>
{
    { "x-delay", TimeSpan.FromSeconds(5) }
};

channel.BasicPublish(
    exchange: "my-delayed-exchange",
    routingKey: "my-routing-key",
    basicProperties: properties,
    body: messageBody);