Inscreve-se em 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”.

• exchangeName (string): Nome da exchange da qual a fila vai receber mensagens.

• exchangeType (ExchangeType): Tipo da exchange. Pode ser:

  • Direct: Roteia mensagens para filas com uma chave de roteamento exata.
  • Fanout: Roteia mensagens para todas as filas ligadas à exchange.
  • Topic: Roteia mensagens para filas com base em padrões de chave de roteamento.
  • Headers: Roteia mensagens com base em cabeçalhos de mensagem.

• queueName (string): Nome da fila que será assinada para receber mensagens da exchange.

Retorno

• List<(bool Ready, string Queue)>: Retorna uma lista de tuplas onde cada tupla contém:
  • Ready (bool): Indica se a assinatura foi criada com sucesso.
  • Queue (string): Nome da fila que foi assinada.

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

Adicionando a subscrição em uma Queue

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

var exchangeName = "myExchangeName";
var queueName = "myQueueName";
var success = Dp.Stream.AddSubscribeRabbitMQ(exchangeName, ExchangeType.Direct, queueName);
  if (success)
  {
      Console.WriteLine("Assinatura criada com sucesso.");
  }
  else
  {
      Console.WriteLine("Falha ao criar a assinatura.");
  }

Considerações

• Certifique-se de que a exchangeName e a queueName estejam corretamente configurados e existam no RabbitMQ.
• O tipo de exchange (exchangeType) deve corresponder à estratégia de roteamento que você deseja implementar.
• 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.