如何在ActiveMQ Artemis中创建非持久队列？

Question

        var source = new Source()
        {
        };

        if (durable)
        {
            source.Address = amqpAddressConverter.GetSubscriberAddress(address, useLoadBalancing);
            source.Durable = 1;
            source.ExpiryPolicy = new Symbol("never");
            source.DistributionMode = new Symbol("copy");
        }
        else
        {
            source.Address = amqpAddressConverter.GetSubscriberAddress(address);
            source.Durable = 0;
            source.ExpiryPolicy = "never";
        }

        var receiverLink = new ReceiverLink(session, linkName, source, null);

因为正如我在Active MQ Artemis文档中看到的，持久值是一个布尔值，但在amqpnetlite库中它是一个uint，我的理解是，超过0的所有内容都应该是true，而0应该是false。

起初，这种行为非常奇怪：即使当Aretemis Web界面显示为持久队列时，一旦没有用户连接，它也会被删除。

我发现：ActiveMQ Artemis queue在关闭消费客户机后被删除，这描述了即使是持久的队列也会因为默认行为而被删除。

那么如何正确地创建持久连接和非持久连接呢？

Answer 1

Artemis源代码在.NET中提供了一个示例，该示例创建了一个持久的主题订阅，并演示了如何稍后使用amqpnetlite恢复该订阅。

许多人忽略的一个关键问题是，您的客户机需要使用一个独特的容器ID，类似于JMS客户机ID概念。

对于特定于队列的订阅，客户端应该在链接功能中指出，它希望创建一个基于队列的地址，因为默认情况下是一个表现不一样的多播队列。

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

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