ActiveMQ 初学-1：ActiveMQ 创建连接对象

 

县创建mq的连接工厂对象 ActiveMQConnectionFactory

 

 

// 1 建立ConnectionFactory 工厂对象，需要填入，需要填入用户名密码，

// 用户名 密码 在 activemq.xml 中安全插件配置
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
         ActiveMQConnectionFactory.DEFAULT_USER,
        //"wator",
         ActiveMQConnectionFactory.DEFAULT_PASSWORD,
        //"wator",
        "tcp://http://192.168.152.142:8161/" // 在activemq.xml 配置文件中，有多种协议连接方式
);

 

 

 

这里的ConnectionFactory 是javax.jms.中的接口。

 

 

---

接下来

 
// 2 通过 ConnectionFactory 创建一个链接对象，打开链接
Connection connection = connectionFactory.createConnection();
connection.start();

 

 

connection 使用前需要调用 start() 方法。

 

这样就创建了一个mq的connection连接对象。