QueueManager 1.0.2

QueueManager

Biblioteca para gerenciar mensagens em diferentes sistemas de fila como IBM MQ e RabbitMQ.

Caracter�sticas

• Suporte para IBM MQ.
• Suporte para RabbitMQ.
• F�brica para cria��o f�cil e integrada de servi�os de fila.
• Estrutura de resultado de opera��o padronizada para mensagens enviadas e recebidas.

Como Usar

1. Configura��o

Primeiramente, crie uma inst�ncia da configura��o desejada: IbmMqConfig para IBM MQ ou RabbitMqConfig para RabbitMQ.

2. Crie uma Inst�ncia do Servi�o de Fila

Use a classe QueueServiceFactory para criar a inst�ncia do servi�o de fila desejado.

var config = new RabbitMqConfig { /* ... propriedades ... */ };
IQueueService queueService = QueueServiceFactory.Create(_logger, config);

3. Envie e receba uma Mensagem

var messageToSend = new BaseMessageSend { /* ... propriedades ... */ };
var sendResult = await queueService.SendMessage(messageToSend);

var receivedResult = await queueService.ReceiveMessage();

Recebendo Mensagens via Consumer

Ambos os servi�os, IBMMQService e RabbitMQService, oferecem uma maneira de come�ar um consumidor que escuta continuamente as mensagens e as processa assim que s�o recebidas.

1. Defina a Fun��o de Processamento de Mensagem

Antes de come�ar o consumidor, voc� precisa definir uma fun��o que ser� chamada para cada mensagem recebida.

async Task ProcessMessage(BaseMessageReceive receivedMessage)
{
    // L�gica de processamento da mensagem aqui
    Console.WriteLine($"Mensagem recebida: {receivedMessage.Payload}");
}

2. �nicie o Consumidor

Use o m�todo StartConsumer para iniciar o consumidor.

var cancellationTokenSource = new CancellationTokenSource();

// Inicia o consumidor
queueService.StartConsumer(ProcessMessage, cancellationTokenSource.Token);

// Para parar o consumidor quando necess�rio
// cancellationTokenSource.Cancel();

Este consumidor continuar� a processar mensagens at� que um sinal de cancelamento seja enviado usando o CancellationToken

Depend�ncias

• IBM.WMQ
• RabbitMQ.Client
• Newtonsoft.Json
• LogManager.Domain