Как указать порт JMX для встроенного экземпляра activemq? - PullRequest
2 голосов
/ 29 июня 2011

Я создаю встроенный экземпляр activemq для тестирования создания / удаления тем через JMX. Код выглядит примерно так: broker.connectorPort был моей попыткой установить порт 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>

1 Ответ

2 голосов
/ 29 июня 2011

Решено созданием брокера вручную ..

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