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客户端代码