Adiciona uma fila no RabbitMQ

Parâmetros

• alias (string, opcional): Parâmetro opcional com o nome do Stream Alias conforme definido na configuração do Stream Adapter. O valor padrão é “Stream1”.

• queueName (string): Nome da fila. Este é o identificador único da fila no RabbitMQ.

• customProperties (CustomQueueProperties, opcional): Propriedades personalizadas para a fila, como configurações de TTL (Time-to-Live), persistência e outras características específicas da fila.

Retorno

• bool: Retorna true se a fila for criada com sucesso; caso contrário, retorna false.

Aqui está um exemplo de como usar o método AddQueueRabbitMQ na sua aplicação:

Criando uma fila sem utilizar as propridades

O parâmetro CustomQueueProperties é opcional e utilizado apenas para customização

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

// The CustomQueueProperties parameter is optional and used only for customization
var queueName = "myQueueName";
bool success = Dp.Stream.AddQueueRabbitMQ(queueName, null);
if (success)
    {
    Console.WriteLine("Fila criada com sucesso.");
    }
    else
    {
    Console.WriteLine("Falha ao criar a fila.");
    }

Criando uma fila com as propridades e argumento nulo

1
2
3
4
5
6
7
8

var customProperties = new CustomQueueProperties
{
    Durable = true,
    Exclusive = false,
    AutoDelete = false,
    Arguments = null
};
Dp.Stream.AddQueueRabbitMQ("queue-with-properties", customProperties);

Criando uma fila com as propridades e argumento configurando TTL

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13

// This parameter is optional and used only for customization
// Creation of a queue with custom properties
var customProperties = new CustomQueueProperties
{
    Durable = true,
    Exclusive = false,
    AutoDelete = false,
    Arguments = new Dictionary<string, object>
    {
        { "x-message-ttl", 600000 } // TTL
    }
};
Dp.Stream.AddQueueRabbitMQ("queue-with-properties", customProperties);

Considerações

• Certifique-se de que o queueName seja único dentro do RabbitMQ para evitar conflitos.
• Utilize as propriedades personalizadas para configurar a fila de acordo com as necessidades específicas da sua aplicação.
• As implementações nativas do RabbitMQ são específicas para essa plataforma e atendem a casos de uso particulares. Caso você migre para outra plataforma de streaming, será necessário ajustar seu código para usar os métodos padrão da Devprime ou os métodos específicos da nova plataforma.