Ohne Kommunikation läuft nichts

static void Main(string[] args)
{
  var factory = new ConnectionFactory();
  factory.HostName = "localhost";

  using (var con = factory.CreateConnection())
  {
    using (var channel = con.CreateModel())
    {
      var basicProperties =
        channel.CreateBasicProperties();
      basicProperties.Persistent = true;

      channel.QueueDeclare(queue: "hello",
        durable: false,
        exclusive: false,
        autoDelete: false,
        arguments: null);

      var msg = "Hallo Welt!";
      var body = Encoding.UTF8.GetBytes(msg);

      while (Console.ReadKey().Key ==
        ConsoleKey.Enter)
      {
        channel.BasicPublish(exchange: "",
          routingKey: "hello",
          basicProperties: basicProperties,
          body: body);
          Console.WriteLine("Message sent!");
      }
    }
  }
}

static void Main(static void Main(string[] args)
{
  var factory = new ConnectionFactory();
  factory.HostName = "localhost";

  using (var con = factory.CreateConnection())
  {
    using (var channel = con.CreateModel())
    {
      channel.QueueDeclare(queue: "hello",
        durable: false,
        exclusive: false,
        autoDelete: false,
        arguments: null);

      var consumer =
        new EventingBasicConsumer(channel);
      consumer.Received += Consumer_Received;

      channel.BasicConsume(queue: "hello",
        autoAck: true,
        consumer: consumer);

      Console.ReadLine();
    }
  }

  Console.ReadLine();
}

private static void Consumer_Received(object
  sender, BasicDeliverEventArgs e)
{
  var body = e.Body;
  var message = Encoding.UTF8.GetString(body);
  Console.WriteLine("Received message: {0}",
    message);
}

var factory = new ConnectionFactory();
factory.HostName = "localhost";

using (var con = factory.CreateConnection())
{
  using (var channel = con.CreateModel())
  {
    channel.QueueDeclare(queue: "worker",
      durable: false,
      exclusive: false,
      autoDelete: false,
      arguments: null);

    var consumer = new EventingBasicConsumer(
      channel);
    consumer.Received += (sender, e) =>
    {
      var body = e.Body;
      var basicProperties = e.BasicProperties;
      var replyProperties =
        channel.CreateBasicProperties();
      replyProperties.CorrelationId =
        basicProperties.CorrelationId;

      var url = Encoding.UTF8.GetString(body);
      Console.WriteLine(
        "Processing url: {0}", url);

      string content = "";

      try
      {
        content = ProcessUrl(url);
      }
      catch (Exception)
      {
        Console.WriteLine(
          "failed to read url {0}", url);
      }
      finally
      {
        var response =
          Encoding.UTF8.GetBytes(content);
        channel.BasicPublish(exchange: "",
          routingKey: basicProperties.
          ReplyTo, basicProperties:
          replyProperties, body: response);
        channel.BasicAck(deliveryTag:
          e.DeliveryTag, multiple: false);
      }
    };

    channel.BasicConsume(queue: "worker",
      autoAck: false,
      consumer: consumer);

      Console.ReadLine();
    }
  }

  Console.ReadLine();
}

private static string ProcessUrl(string url)
{
  string content = "";
  using (WebClient client = new WebClient())
  {
    content = client.DownloadString(url);
  }

  return content;
}

var replyQueue = channel.QueueDeclare().QueueName;
var basicProperties =
  channel.CreateBasicProperties();
basicProperties.Persistent = true;
basicProperties.ReplyTo = replyQueue;
basicProperties.CorrelationId =
  Guid.NewGuid().ToString();

channel.QueueDeclare(queue: "worker",
  durable: false,
  exclusive: false,
  autoDelete: false,
  arguments: null);

var url = "http://www.dotnetpro.de";
var body = Encoding.UTF8.GetBytes(url);

var consumer = new EventingBasicConsumer(channel);
consumer.Received += (m, e) =>
{
  var response = e.Body;
  var content = Encoding.UTF8.GetString(response);
  Console.WriteLine(content);
};
channel.BasicConsume(queue: replyQueue,
  consumer: consumer, : true);

while (Console.ReadKey().Key == ConsoleKey.Enter)
{
  channel.BasicPublish(exchange: "",
    routingKey: "worker",
    basicProperties: basicProperties,
    body: body);
  Console.WriteLine("Work published.");
}