如何使用带有FakeConnectionFactory类的AsyncEventingBasicConsumer (rabbitmq - c#)对消费者进行单元测试？

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using Xunit;

var factory = new FakeConnectionFactory();
var connection = factory.CreateConnection();
var channel = connection.CreateModel();

var consumer = new AsyncEventingBasicConsumer(channel);

Task HandleMessage(object sender, BasicDeliverEventArgs args)
{
    // 处理接收到的消息
    // ...
    return Task.CompletedTask;
}

consumer.Received += HandleMessage;

var message = Encoding.UTF8.GetBytes("Test message");
channel.BasicPublish(exchange: "", routingKey: "queue_name", basicProperties: null, body: message);

await consumer.HandleBasicDeliver("consumer_tag", 1, false, "exchange", "routing_key", null, message);

// 进行断言验证