RabbitMQ，EasyNetQ队列名称

Question

我的队列名称是"TaskQueue“，但当我运行代码时，会创建一个名称为"System_String:mscorlib_TaskQueue”的新队列。下面是我的订阅者代码。我的错是什么？

var bus = RabbitHutch.CreateBus("host=localhost;username=guest;password=guest");
bus.SubscribeAsync<string>("TaskQueue", (msg) =>
    Task.Factory.StartNew(() =>
    {
       Console.WriteLine("Got Message: {0}", msg);
    }));

Answer 1

基本上你做的是对的。但是，TaskQueue是订阅id，而不是生成的队列的名称。

默认情况下，EasyNetQ将使用订阅id和消息类型来生成队列名称。因此，它被命名为System_String:mscorlib_TaskQueue，因此id为TaskQueue的所有订阅都将被视为并发消费者。

请参阅https://github.com/EasyNetQ/EasyNetQ/wiki/Subscribe

您可以使用Taking Control Of The SubscriptionId Generation更改此行为