ConnectionFactory connectionFactory;//连接工厂

Connection connection;//连接

Session session;

Destination destination;//目的

MessageProducer messageProducer;//消息生产者

Message message;//消息

MessageConsumer messageConsumer;//消息消费者

//ActiveMQ用户名、ActiveMQ密码、ActiveMQ地址

connectionFactory = new ActiveMQXAConnectionFactory("admin", "admin", "failover://tcp://localhost:61616");

//连接

connection = connectionFactory.createConnection();

//第一个参数是否使用事务,第二个参数消息的确认模式

session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//指定消息提供者在每次收到消息时自动发送确认。消息只向目标发送一次

//目的地，ActiveMQ中已存在队列

destination = session.createQueue("SecondQueue");

//消息生产者[发送者]

messageProducer = session.createProducer(destination);

//持久性设置

messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

//消息

message = session.createTextMessage("发了一条消息给SecondQueue");

//发送

messageProducer.send(message);

session.close();

connection.close();