asp.net-core - 使用 RawRabbit 发布消息时如何指定队列名称

Question

到目前为止，我发现可以RawRabbit.Enrichers.Attributes使用属性安装包和配置消息类：

[Queue(Name = "my_queue"]
private class AttributedMessage
{       
}

并设置

var client = RawRabbitFactory.CreateSingleton(new RawRabbitOptions
{
    Plugins = plugin => plugin.UseAttributeRouting()
});

但我宁愿指定队列名称以及发布命令以使其更灵活：

await _busClient.PublishAsync(message /*some_config_here???*/);

RawRabbit 2.0.0-rc5 可以吗？

Answer 1

我认为这可能会对您有所帮助：

    static async Task Publish()
    {
        var config = new RawRabbitConfiguration
        {
            Username = "YOUR_RMQ_USER",
            Password = "YOUR_RMQ_PWD",
            Port = 5672,
            VirtualHost = "/",
            Hostnames = { "YOUR_RMQ_HOST_OR_IP" }
        };
        var bus = BusClientFactory.CreateDefault(config);


        await bus.PublishAsync(
            message: yourAwesomeMessagePayload,
            configuration: ctx => ctx.WithExchange(BuildExchangeConfig)
                                     .WithRoutingKey("custom.message.routing.key")
            );

        Console.WriteLine("message published!");
    }

    static void BuildExchangeConfig(IExchangeConfigurationBuilder e)
    {
        e.WithName("YOUR_EXCHANGE_NAME")
            .WithAutoDelete(false)
            .WithDurability(true)
            .WithType(ExchangeType.Topic);
    }