1

次のコードを使用して、生のメッセージをキューに発行します。

using (var bus = RabbitHutch.CreateBus("host=myserver;virtualHost=myhost;username=xxx;password=yyy").Advanced)
{
    var queue = bus.QueueDeclare("MyQueue");
    var exchange = bus.ExchangeDeclare("MyExchange", ExchangeType.Topic);
    var binding = bus.Bind(exchange, queue, "");
    var properties = new MessageProperties();
    var body = System.Text.Encoding.UTF8.GetBytes("This is the body of the message");

    bus.Publish(exchange, "", false, false, properties, body);
}

メッセージがキューに配信され、RabbitMQ のコンソールからキューに 1 つのメッセージが表示されます。ただし、次のコードでそれを消費しようとすると、何も返されません。

bus.Consume(queue, (body, properties, info) => Task.Factory.StartNew(() =>
{
    var message = Encoding.UTF8.GetString(body);
    Console.Out.WriteLine("Got message: '{0}'", message);
}));

メッセージが Rabbit のコンソールから配信されていることがわかりますが、何も出力されず、メッセージはまだキューに入っています。私は何が欠けていますか？

4

0 に答える 0