.NET에서 Docker를 사용하는 RabbitMQ 대기열

The RabbitMQ  Queue  is positioned in the  Message Broker  section with the  Exchange , and can be seen as buffer storage, that receives messages through a stream based on the  binding key  from the  Exchange  which also receives the messages from one or many  Producers . They are acting like a Queue Data Structure, that can be  enqueued  and  dequeued , using the FIFO rule.\
Some tips about the  Queues , that I find useful are:

• A  Queue  name can't start the  amq  name, because is restricted by the  Broker  for internal usages.
• If the  Queue  name is not specified a random one will be assigned to it.
• Queues  with the same name can be created on the same channel, by only the last one will be kept.

To start creating a  Queue  firstly the connection to the RabbitMQ server should be built using the  ConnectionFactory ; is the same setup as in the previous article about RabbitMQ  Exchange  using a  URI . But in the first article where the  Producer  is created, the connection was created using explicit properties of  ConnectionFactory  (i.e.  Hostname ,  UserName  and  Password ).

As you can see in the below chunk code, all these properties are embedded into one  Uri  instance.

var factory = new ConnectionFactory
{
    Uri = new Uri("amqp://guest:guest@localhost"),
    ContinuationTimeout = TimeSpan.MaxValue
};

When the required properties are entered, for each  Queue  a  Connection  and a communication  Channel  will be created. After that, the  Queue  is declared, and the bound to the  Exchange  that has the same name for the entire solution (i.e. test-exchange). If the creation and the binding were ended successfully, then a message is prompted informing the user that the  Queue  was created.

...
    using (IConnection connection = factory.CreateConnection())
    {
        using (channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: queueName,
                durable: false,
                exclusive: false,
                autoDelete: false,
                arguments: null);

            channel.QueueBind(queue: queueName,
                exchange: "test-exchange",
                routingKey: routingKey);
        }
    }

    Console.WriteLine(value: $"Queue {queueName} created.");
}

Let's dig a little bit deep into the parameters of the  QueueDeclare :

• queue  it's self-evident that it refers to the  Queue  name;
• durable  represents the lifetime of the  Queue  in the  Broker , if it's set to false the  Queue  will end when the  Broker  does too;
• autoDelete  is used to specify the lifetime of the  Queue  based on its subscriptions. The  Queue  will be deleted if the last  Consumer  subscribed to it, unsubscribes;
• arguments  are used to sent information about the  Queue  (e.g. length limit) to the  Broker ;

QueueBind 's parameters are self-explanatory, the first one refers to the  queueName , the second to the  exchangeName  and the last one to the  routingKey .

After the  Queues  are created, a message is prompted to the user with how many  Queues  were created.