/
dimkqa
/
RabbitMQ-Learning
Обзор
Документация
Войти
/
dimkqa
/
RabbitMQ-Learning
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
RabbitMQ.Console.Consumer/Program.cs
28 строк
954 B
shamrik-dmitriy
= Немного порядка и изменений в наименованиях
10 мар 2025, 19:32
10 мар 2025, 19:32
7730034
Код
Авторство
О чём код?
using System; using System.Threading; using System.Threading.Tasks; using RabbitMQ.Client; namespace RabbitMQ.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("MyFirstQueue", 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(); } } }