java - 如何以编程方式在 ActiveMQ 中启用优先级队列？

Question

我想在 ActiveMQ 中使用优先级消息队列。根据此链接，默认情况下它是禁用的。我正在使用嵌入式 MessageBroker。是否可以以编程方式启用优先级。我没有这样的xml配置文件。

问候

Answer 1

那么，您是使用纯 java 嵌入吗？

你应该尝试这样的事情：

BrokerService bs = new BrokerService();
    bs.addConnector("tcp://localhost:61616");
    PolicyMap pm = new PolicyMap();
    PolicyEntry pe = new PolicyEntry();
    pe.setPrioritizedMessages(true);
    pm.setDefaultEntry(pe);
    bs.setDestinationPolicy(pm);
    bs.start();

如果您使用 spring 嵌入 ActiveMQ，请注意 ActiveMQ dist 中的 activemq.xml。只不过是一个简单的 spring 上下文文件，它创建具有各种属性的代理。