关闭消费客户端后ActiveMQ Artemis队列被删除

Question

之后，我尝试从其他应用程序使用者那里使用该消息。这没有问题。

我的应用程序使用者是用Spring Boot构建的，如下所示：

@SpringBootApplication
public class ProcessorClaimsApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProcessorClaimsApplication.class, args);
    }

}

@EnableJms
@Configuration
public class ProcessorClaimsConfig {
    private static final Logger LOGGER = LoggerFactory.getLogger(ProcessorClaimsConfig.class);
    private static final String ORDER_ID = "orderId";
    private static final String APPROVED = "approved";
    private static final String APPROVERS = "approvers";
    private static final String APPOVER_INFO_SEPARATOR = ":";
    private static final String APPROVERS_SEPARATOR = ";";

    @Autowired
    private AS2Service as2Service;

    @Autowired
    private EnsuranceService ensuranceService;

    ...

    @Transactional
    @JmsListener(destination = "requests", selector = "JMSType = 'PAYMENTORDERAPPROVALRESPONSE'")
    public void processZMessageResponse(MapMessage message) {
        try {
            LOGGER.debug("Incoming message found JMSCorrelationID {}, orderId {}", message.getJMSCorrelationID(),
                    message.getStringProperty(ORDER_ID));
            boolean approved = (Boolean) message.getObject(APPROVED);
            String approvers = (String) message.getObject(APPROVERS);
            LOGGER.debug("Sending resolution to Ensurance");
            ensuranceService.sendResolution(Long.valueOf(message.getJMSCorrelationID()),
                    message.getStringProperty(ORDER_ID), approved, approvers);
        } catch (Exception e) {
            LOGGER.error("The is an error processing the message: {}" + e.getMessage());
            e.printStackTrace();
        }
    }
}

顺便说一句，最初的requests队列是在应用程序生成器将消息发送到ActiveMQ Artemis时创建的，并使用JMSTemplate完成，如下所示：

public void pushResolution(String jmsCorrelationID, final String paymentOrderId, 
        final String paymentOrderNumber, final String paymentOrderType, Map<String, Object> data) {
        this.jmsTemplate.send(requestsQueue, new MessageCreator() {

            @Override
            public Message createMessage(Session session) throws JMSException {
                MapMessage message = session.createMapMessage();
                for (String key : data.keySet()) {
                    message.setObject(key, data.get(key));
                }
                message.setJMSCorrelationID(jmsCorrelationID);
                message.setJMSType(MessageTypeEnum.PAYMENTORDERAPPROVALRESPONSE.name());
                message.setStringProperty("orderId", paymentOrderId);
                message.setStringProperty("orderNumber", paymentOrderNumber);
                message.setStringProperty("orderType", paymentOrderType);
                return message;
            }
            
        });

        LOGGER.debug("Pushed Payment Order Response in Queue successfully.");
    }

Answer 1

您所看到的是意料之中的，因为这是ActiveMQ Artemis的默认行为。地址和队列将自动创建和删除。地址和队列是响应客户端发送消息或客户端创建消费者而创建的。一旦队列中没有更多的消息并且最后一个使用者断开连接，队列就会被移除，因为不再需要它。当没有更多的队列绑定到一个地址时，它也会被移除。如有需要，这些资源将再次被重新创建。

您可以通过以下地址设置来控制此行为：

• 自动创建队列
• 自动删除队列
• 自动创建地址
• 自动删除地址

您可以通过以下地址设置微调行为：

• 自动删除-队列-延迟
• 自动删除-队列-消息-计数
• 自动删除-地址-延迟

有关更多详细信息，请参见文档。