AMQPNETLITE - ActiveMQ Artemis（Red Hat AMQ）- 自动创建多消费者组播队列

Question

AMQPNETLITE - ActiveMQ Artemis（Red Hat AMQ）- 自动创建多消费者组播队列

5

这个问题涉及使用AMQP在 .Net 环境下消费消息。官方文档推荐使用 amqpnetlite：https://access.redhat.com/documentation/en-us/red_hat_amq/7.0/html-single/using_the_amq_.net_client/index。在使用 AMQPNetLite 订阅地址时，地址和队列将被自动创建。但是，自动创建的队列始终是“单播”的。我无法自动创建以下内容：

可允许任意数量消费者的多播队列。

代码：

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;
}

也许我漏了一些标志？

- Praveen Nayak

已经找到了第一个问题的解决方案 - 创建多播队列是使用源能力：Capabilities = new[] { new Symbol("topic") }，//或者使用“queue”来请求队列。 - Praveen Nayak

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- user7610 · Accepted Answer

在AMQP中，您可以通过设置一个能力来选择自动创建队列（单播路由）或主题（多播路由）。

该能力应为new Symbol("queue")或new Symbol("topic")。

public class SimpleAmqpTest
{
    [Fact]
    public async Task TestHelloWorld()
    {
        Address address = new Address("amqp://guest:guest@localhost:5672");
        Connection connection = await Connection.Factory.CreateAsync(address);
        Session session = new Session(connection);

        Message message = new Message("Hello AMQP");

        Target target = new Target
        {
            Address = "q1",
            Capabilities = new Symbol[] { new Symbol("queue") }
        };

        SenderLink sender = new SenderLink(session, "sender-link", target, null);
        await sender.SendAsync(message);

        Source source = new Source
        {
            Address = "q1",
            Capabilities = new Symbol[] { new Symbol("queue") }
        };

        ReceiverLink receiver = new ReceiverLink(session, "receiver-link", source, null);
        message = await receiver.ReceiveAsync();
        receiver.Accept(message);

        await sender.CloseAsync();
        await receiver.CloseAsync();
        await session.CloseAsync();
        await connection.CloseAsync();
    }
}

请查看 https://github.com/Azure/amqpnetlite/issues/286，这里是代码来源。

您可以通过在broker.xml中设置default-address-routing-type来选择默认路由是多播还是任播，所有内容均记录在https://activemq.apache.org/artemis/docs/2.6.0/address-model.html。

AMQP不支持broker的multicastPrefix和anycastPrefix功能。 https://issues.jboss.org/browse/ENTMQBR-795。