DAS_2024_1/kuzarin_maxim_lab_4/HelloWorld/Receiver.cs

71 lines
2.2 KiB
C#
Raw Permalink Normal View History

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Channels;
using System.Threading.Tasks;
namespace HelloWorld
{
public class Receiver : IDisposable
{
private readonly ConnectionFactory _connectionFactory;
private readonly IConnection _connection;
private readonly IModel _channel;
private readonly string _queueName;
public Receiver(string brockerHost, string brockerUsername, string brockerPassword, string queueName)
{
_queueName = queueName;
_connectionFactory = new ConnectionFactory() { HostName = brockerHost, UserName = brockerUsername, Password = brockerPassword };
_connection = _connectionFactory.CreateConnection();
_channel = _connection.CreateModel();
_channel.QueueDeclare(queue: _queueName,
durable: true,
exclusive: false,
autoDelete: false,
arguments: null);
_channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);
}
public bool AddMessageHandler(Action<string> handler)
{
try
{
var consumer = new EventingBasicConsumer(_channel);
consumer.Received += (model, ea) =>
{
var messageBody = ea.Body.ToArray();
var messageText = Encoding.UTF8.GetString(messageBody);
handler(messageText);
_channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
};
_channel.BasicConsume(queue: _queueName,
autoAck: false,
consumer: consumer);
return true;
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
return false;
}
~Receiver() => Dispose();
public void Dispose()
{
_connection.Dispose();
_channel.Dispose();
}
}
}