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();
}