JMS 之 Active MQ 啟動嵌入式Broke

一、如何啟動active MQ 服務

(一)、使用命令啟動

   a、/usr/local/activemq-5.9.0/bin 目錄下 ./activemq start   默認使用conf/activemq.xml 配置文件
   b、[[email protected] bin]# ./activemq start xbean:file:../conf/activemq-slave1.xml  使用指定的配置文件啟動

 

(二)、代碼啟動broker

  在程序中可以通過編碼的方式啟動broker,如果要啟動多個broker需要為每一個broker設置名字  broker.setName("brokerOne")

1、使用BrokerService 啟動broker

    public static void main(String[] args) throws Exception {
        BrokerService broker=new BrokerService();
        broker.setUseJmx(true);
        broker.addConnector("tcp://localhost:61616");
        broker.start();
    }

 

2、使用BrokerFactory啟動broker

private static void brokerFactoryStart() throws Exception{
        String uri="properties:broker.properties";
        BrokerService broker=BrokerFactory.createBroker(new URI(uri));
        broker.addConnector("tcp://localhost:61616");
        broker.start();
    }

 

broker.properties:

 

useJmx=true
persistent=false
brokerName=Cheese

 

3、使用spring

spring-activemq.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="//www.springframework.org/schema/beans"
    xmlns:amq="//activemq.apache.org/schema/core"
    xmlns:xsi="//www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="//www.springframework.org/schema/beans //www.springframework.org/schema/beans/spring-beans-2.0.xsd
    //activemq.apache.org/schema/core //activemq.apache.org/schema/core/activemq-core.xsd
    //camel.apache.org/schema/spring //camel.apache.org/schema/spring/camel-spring.xsd">
    <bean id="jmsBroker" class="org.apache.activemq.broker.BrokerService" init-method="start" destroy-method="stop">
      <property name="brokerName" value="myBroker"/>
      <property name="persistent" value="false"/>
      <property name="transportConnectorURIs">
          <list>
              <value>tcp://localhost:61616</value>
          </list>
      </property>
    </bean>
</beans>

 

private static void springStart() throws Exception{
        ApplicationContext context=new ClassPathXmlApplicationContext("spring-activemq.xml");
        BrokerService broker=(BrokerService) context.getBean("jmsBroker");
        broker.start();
    }

來源:itnose 

 

上一篇: Lucence_Curd

下一篇: Java反射定義、獲取Class三種方法

分享到: 更多
腾讯三公游戏下载 安徽时时开奖结果 重庆市彩专家计划软件下载 正规牛牛 pk10人工免费计划 牛牛赚钱1元永久提现 双色球开奖查询结果 二十一点单机游戏 赛车345678必中技巧 通比牛牛手机版 七星彩今晚预测 免费麻将单机 大乐透开奖结果彩票 牛牛棋牌代理 三分pk10冠军稳赚技巧 斗地主棋牌提现