如何在正在运行的IBusControl上添加发布消息配置

// 创建一个消息类型
public class MyMessage
{
    public string Text { get; set; }
}

// 创建一个消息处理程序
public class MyMessageHandler : IConsumer<MyMessage>
{
    public Task Consume(ConsumeContext<MyMessage> context)
    {
        Console.WriteLine($"Received message: {context.Message.Text}");
        return Task.CompletedTask;
    }
}

// 配置消息总线的发布者
var busControl = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
    var host = cfg.Host(new Uri("rabbitmq://localhost"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });

    cfg.ReceiveEndpoint(host, "my_queue", e =>
    {
        e.Consumer<MyMessageHandler>();
    });
});

// 在正在运行的IBusControl上应用配置
busControl.Start();

// 发布消息
var message = new MyMessage { Text = "Hello, World!" };
busControl.Publish(message);