如何为嵌入式activemq实例指定JMX端口

Question

我正在创建一个嵌入式activemq实例，以便测试通过JMX创建/删除主题。代码看起来有点像下面的代码。broker.connecterPort是我设置JMX端口的尝试，但它不起作用。

String connectString="vm://localhost?broker.persistence=false&broker.useJmx=true&broker.connectorPort=2011"
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
activeMQConnectionFactory.setBrokerURL(connectString);
ActiveMQConnection activeMQConnection = (ActiveMQConnection) activeMQConnectionFactory.createConnection();
activeMQConnection.start();

使用activemq.xml进行配置时，以下xml有效。我不知道如何将其翻译成brokerURL。

<managementContext>
        <managementContext connectorPort="2011" createConnector="true"/>
</managementContext>

Answer 1

通过手动创建broker解决。。

    BrokerService broker = new BrokerService();
    broker.setUseJmx(true);
    broker.getManagementContext().setConnectorPort(9999);
    broker.start();