ActiveMQ学习笔记之九--发送消息到队列中
ActiveMQ客户端最小依赖JAR包：
?public?static?void?testSend()?throws?Exception {
????ConnectionFactory factory =?new?ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER/*NULL*/,
???????ActiveMQConnection.DEFAULT_PASSWORD/*NULL*/,?"tcp://localhost:61616");
????Connection connection = factory.createConnection();
????connection.start();
?
????Session session = connection.createSession(true/*支持事务*/, Session.AUTO_ACKNOWLEDGE);
????Destination queue = session.createQueue("test_123");
????MessageProducer producer = session.createProducer(queue/*也可以为NULL，则在发送时才指定目标队列*/);
????producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
?
????TextMessage message = session.createTextMessage();
????message.setText("你好！！");
????message.setJMSPriority(Message.DEFAULT_PRIORITY);
????producer.send(message);
?
????session.commit();
????session.close();
????connection.close();
}
执行上面代码，然后观察Jconsole和webconsole的变化：
?
?附件：ActiveMQ客户端代码
