ActiveMQ向消息队列存入消息（点对点模式）

<dependency>
      <groupId>org.apache.activemq</groupId>
      <artifactId>activemq-core</artifactId>
      <version>5.7.0</version>
    </dependency>

package com.vhukze.Producer;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;
public class ProducerTest {
    //mq通讯地址
    private static String url = "tcp://127.0.0.1:61616";
    //队列名称
    private static String queueName = "my_queue";
    public static void main(String[] args) throws JMSException {
        //创建连接工厂
        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(url);
        //创建连接
        Connection connection = factory.createConnection();
        //启动连接
        connection.start();
        //创建会话，参数1，设置是否需要事务方式提交，参数2，消息方式  默认采用自动接收
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //创建目标(队列)
        Queue queue = session.createQueue(queueName);
        //创建生产者
        MessageProducer producer = session.createProducer(queue);
        for (int i = 0; i <= 10 ; i++) {
            //创建消息
            TextMessage textMessage = session.createTextMessage("消息内容" + i);
            //发送消息
            producer.send(textMessage);
        }
        connection.close();
    }
}