2011-06-29 15 views
2

JMX経由でトピックの作成/削除をテストするために、組み込みのactivemqインスタンスを作成しています。 コードは次のようになります。 broker.connectorPortはJMXポートを設定しようとしましたが、動作しません。組み込みactivemqインスタンスの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> 

答えて

2

..

BrokerService broker = new BrokerService(); 
    broker.setUseJmx(true); 
    broker.getManagementContext().setConnectorPort(9999); 
    broker.start(); 
関連する問題