小编Pra*_*yak的帖子

这个问题是在 .Net 中使用 AMQP 来消费消息。文档推荐 amqpnetlite：https ://access.redhat.com/documentation/en-us/red_hat_amq/7.0/html-single/using_the_amq_.net_client/index

使用 AMQPNetLite 订阅地址时，将自动创建地址和队列。不过，自动创建的队列始终是“单播”的。我无法自动创建

1. 多播队列
2. 这允许任意数量的消费者。

代码：

private async Task RenewSession()
{
    Connect = await Connection.Factory.CreateAsync(new Address("amqp://admin:admin@localhost:5672"), new Open() {ContainerId = "client-1"});
    MqSession = new Session(Connect);
    var receiver = new ReceiverLink(MqSession, DEFAULT_SUBSCRIPTION_NAME, GetSource("test-topic"), null);
    receiver.Start(100, OnMessage);
}

private Source GetSource(string address)
{
    var source = new Source
    {
        Address = address,
        ExpiryPolicy = new Symbol("never"),
        Durable = 2,
        DefaultOutcome = new Modified
        {
            DeliveryFailed = true,
            UndeliverableHere = false
        }
    };
    return source; …