public static void main(String[] args) throws JMSException {
String url = "tcp://localhost:61616";
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
url);
// 设置用户名和密码,这个用户名和密码在conf目录下的credentials.properties文件中,也可以在activemq.xml中配置
connectionFactory.setUserName("system");
connectionFactory.setPassword("manager");
// 创建连接
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
// 创建目标,就创建主题也可以创建队列
Destination destination = session.createQueue("1230");
// 创建消息消费者
MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
String selector = "JMSCorrelationID='" + "1001" + "'";
MessageConsumer consumer = session.createConsumer(destination,selector);
TextMessage tm = session.createTextMessage("12345111");
tm.setJMSCorrelationID("1001");
producer.send(tm);
while(true){
TextMessage tm1 = (TextMessage) consumer.receive(1000);
if(null!=tm1){
System.out.println(tm1);
tm1.acknowledge();
System.out.println(tm1.getText());
}
else
break;
}
consumer.close();
producer.close();
session.close();
connection.close();
}
}