我可以使用以下代碼成功發布消息: 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 不能為空
- 3 回答
- 0 關注
- 287 瀏覽
添加回答
舉報
0/150
提交
取消