自动删除地址在ActiveMQ Artemis中不起作用

Question

当不再使用该地址时，我遇到的问题会自动删除动态地址。

以下是Broker.xml的摘录：

         <address-setting match="#">
            <dead-letter-address>DLQ</dead-letter-address>
            <expiry-address></expiry-address>
            <redelivery-delay>0</redelivery-delay>
            <expiry-delay>10</expiry-delay>
            <max-size-bytes>-1</max-size-bytes>
            <max-size-messages>-1</max-size-messages>
            <message-counter-history-day-limit>10</message-counter-history-day-limit>
            <address-full-policy>PAGE</address-full-policy>
            <auto-create-queues>true</auto-create-queues>
            <auto-create-addresses>true</auto-create-addresses>
            <auto-delete-queues>true</auto-delete-queues>
            <auto-delete-addresses>true</auto-delete-addresses>
            <auto-delete-created-queues>true</auto-delete-created-queues>
            <auto-delete-queues-message-count>-1</auto-delete-queues-message-count>
         </address-setting>

以下是创建主题的生产者代码：

    /////////////////////////////////////
    //Constructor to establish connection
    /////////////////////////////////////
    
    public ActiveMQ(String amq_url) throws JMSException, NamingException{
        jndi_env = new Hashtable<String, Object>();
        jndi_env.put(InitialContext.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
        jndi_env.put(InitialContext.PROVIDER_URL, amq_url);
        ic = new InitialContext(jndi_env);
        ConnectionFactory connectionFactory = (ConnectionFactory) ic.lookup("ConnectionFactory");
        this.connection = (ActiveMQConnection) connectionFactory.createConnection();
        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    }
    
    ///////////useTopic()///////////
    //create/select topic
    ////////////////////////////////    
    public void useTopic(String topicName) throws JMSException, NamingException{
        if (producer != null) producer.close();
        this.topic = (Destination) ic.lookup("dynamicTopics/"+topicName);
        this.producer = session.createProducer(topic);
    }

    public void closeConnection() throws JMSException{
        if (producer != null) producer.close();
        if (connection != null) connection.stop();
        if (session != null) session.close();
        if (connection != null) connection.close();
    } 

}

当在ActiveMQ Artemis中创建地址时，它看起来与下拉列表中的其他其他代码（EG Test_sdcdata vs expryqueue）。

我和我的同事无法弄清楚为什么在不重新启动ActiveMQ Artemis服务器的情况下，该特定地址不会基于上述删除。该控制台表明，在我停止创建主题的程序后，没有任何消费者或生产者连接。该主题基于ActiveMQ Artemis Web控制台的消息数为0。有什么想法吗？我觉得我没有设置需要设置的特定价值。

Answer 1

据我所知，一切都按设计工作。让我解释一下...

当JMS客户端向主题发送消息时，自动创建 - addresses是true，经纪人将通过根据根据命名命名的地址来响应消息发送的位置。但是，由于JMS主题没有消费者，因此消息将简单地删除。这符合基本发布/订阅语义。

目前将无法删除该地址，因为经纪人知道没有在其上创建任何消费者，因此实际上并未在功能上使用。如果经纪人在这种情况下删除地址，则必须在发送另一条消息时立即重新创建它。随着消息被发送到浪费宝贵的资源，它最终会一遍又一遍地创建和删除地址。经纪人通过等待至少在地址上创建了一个消费者之前避免这种病理状况（即消费者断开连接后）。

您的地址看起来与Web控制台中的“ Expiryqueue”和“ DLQ”地址不同的原因是因为这两个地址上有队列。您的地址以及“ ActiveMQ.Theotifications”地址没有队列。

如果您不清楚地址和队列如何相互关系，则可以在文档。