/
dimkqa
/
RabbitMQ-Learning
Обзор
Документация
Войти
/
dimkqa
/
RabbitMQ-Learning
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
RabbitMQ.SimulationTasks.Console.Consumer/Program.cs
28 строк
991 B
shamrik-dmitriy
+ Добавил простой пример имитирующий длительную работу.
15 мар 2025, 13:30
15 мар 2025, 13:30
459adfd
Код
Авторство
О чём код?
using System.Threading; using System.Threading.Tasks; using RabbitMQ.Client; namespace RabbitMQ.SimulationTasks.Console.Consumer { class Program { static async Task Main(string[] args) { var cancellationToken = new CancellationTokenSource().Token; var connectionFactory = new ConnectionFactory() { HostName = "localhost" }; using var connection = await connectionFactory.CreateConnectionAsync(cancellationToken); using var channel = await connection.CreateChannelAsync(cancellationToken: cancellationToken); await channel.QueueDeclareAsync("QueueOfSimulationTasks", false, false, false, null, cancellationToken: cancellationToken); var consumer = new Consumer(channel); System.Console.WriteLine(" [*] Waiting for messages."); var message = await consumer.Receive(); System.Console.ReadLine(); } } }