java - 从 activemq.xml 文件中读取 Broker 配置并使用 Java 代码启动 Broker

Question

我想读取 some_dir/activemq.xml 文件，以便可以使用 org.apache.activemq.broker.BrokerService 创建代理，该代理将具有所提供文件的所有配置。我尝试以编程方式设置属性:

TransportConnector tc = new TransportConnector();
    tc.setName("openwire");
    tc.setUri(new URI("tcp://localhost:61616?trace=true"));
    
    List<TransportConnector> tcList = new ArrayList<TransportConnector>();
    tcList.add(tc);
    broker.setTransportConnectors(tcList);
    
    DiscoveryNetworkConnector nc =  new DiscoveryNetworkConnector();
    nc.setName("Q:broker1->broker2");
    nc.setUri(new URI("static:(tcp://localhost:61616)"));
    nc.setDuplex(false);
    nc.setDecreaseNetworkConsumerPriority(false);
    nc.setNetworkTTL(2);
    nc.setDynamicOnly(true);
    
    List<DiscoveryNetworkConnector> ncList = new ArrayList<DiscoveryNetworkConnector>();
    ncList.add(nc);
    
    broker.setNetworkConnectors(ncList);
    
    
    System.out.println(broker);
    //broker.startTransportConnector(tc);
    //broker.startAllConnectors();
    broker.start();

但是很长。有什么办法可以做到broker.readConfigFile(“/conf/activemq.xml”)

或者这是不可能的(尽管我认为是)。因此启动代理的唯一方法是从命令行并编写 java 客户端(生产者/消费者)来连接到它。

Answer 1

尝试

org.apache.activemq.broker.BrokerService broker = org.apache.activemq.broker.BrokerFactory.createBroker(new URI("xbean:file:some_dir/activemq.xml"));
broker.start();

<dependency>
  <groupId>org.apache.activemq</groupId>
  <artifactId>activemq-all</artifactId>
  <version>5.xx.x</version>
</dependency>

http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html