EasynetQ bus.Subscribe 未触发 - 抛出“messageType 不能为空”

Question

我可以使用以下代码成功发布消息：

        using (IAdvancedBus bus = RabbitHutch.CreateBus("host=192.168.153.128:5672;username=user;password=pass").Advanced)

        {

            IExchange exchange = bus.ExchangeDeclare("milk.api", ExchangeType.Topic);

            IQueue queue = bus.QueueDeclare("milkorderqueue");

            IBinding binding = bus.Bind(exchange, queue, "#");

            bus.Publish<MilkOrderRequest>(exchange, "#", true, new Message<MilkOrderRequest>(milkOrder));

        }

        return new HttpResponseMessage(System.Net.HttpStatusCode.OK);

当我的订阅者尝试接收消息时，EasyNetQ_Default_Error_Queue 队列会增加。这是侦听器的代码：

        IBus bus = RabbitHutch.CreateBus(@"host=192.168.153.128:5672;username=user;password=pass");

        bus.Subscribe<MilkOrderRequest>("my_subscription_id", message =>

        {

            Console.WriteLine($"Order recieved: {message.Milk}.");

        }, config =>

        {

            config.WithQueueName("milkorderqueue");

        });

我也尝试了以下方法但没有成功：

        IAdvancedBus bus = RabbitHutch.CreateBus(@"host=192.168.153.128:5672;username=user;password=pass").Advanced;

        IExchange exchange = bus.ExchangeDeclare("milkshop.subscriber", ExchangeType.Topic);

        IQueue queue = bus.QueueDeclare("milkorderqueue");

        bus.Bind(exchange, queue, "#");

        bus.Consume<MilkOrderRequest>(queue, (message, info) =>

        {

            Console.WriteLine($"Order recieved: {message.Body.Milk}.");

        });

我无法在 Google 上找到有关异常的答案：

messageType 不能为空

Answer 1

发现错误。我的 API 项目和控制台应用程序使用不同版本的 EasynetQ nuget 包。一个是 2.33，另一个是 3.0.0。

Answer 2

在我的情况下，问题与使用旧版本 ENQ 的发布者服务有关，而后者又使用LegacyTypeNameSerializer。在使用较新版本 ENQ 的消费服务端，我所要做的就是在创建总线时添加以下内容：serviceRegister.EnableLegacyTypeNaming();这是一种扩展方法，应该包含在较新版本的 ENQ 中。