static void Main(string[] args) { var factory = new ConnectionFactory(); factory.Uri = new Uri("amqp://guest:guest@localhost:5672"); using var connection = factory.CreateConnection(); IModel channel = connection.CreateModel(); channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false); var consumer = new EventingBasicConsumer(channel); //Kullanıcının dinlemek istediği tipi belirlemesini sağlıyoruz. Console.WriteLine("Dinlemek istediğiniz log tipini(Error,Warning,Info) belirtiniz:"); var selectedType = Console.ReadLine(); var queueName = $"direct-queue-{selectedType}"; //Yukarıda oluşturulan queueName'i burada kullanıyoruz. channel.BasicConsume(queue: queueName, autoAck: false, consumer: consumer); consumer.Received += (object sender, BasicDeliverEventArgs e) => { var message = Encoding.UTF8.GetString(e.Body.ToArray()); Thread.Sleep(1000); Console.WriteLine("Gelen Mesaj: " + message); channel.BasicAck(deliveryTag: e.DeliveryTag, multiple: false); }; Console.ReadKey(); }