ActiveMQ的学习之PTP模式
public static void main(String[] args) throws Exception{ ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); Connection connection = connectionFactory.createConnection(); connection.start(); final Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE); Destination destination = session.createQueue("xujiawei-second"); MessageConsumer consumer = session.createConsumer(destination); //Listener模式为异步模式，同步模式为消费者主动去接受信息 consumer.setMessageListener(new MessageListener(){ public void onMessage(Message msg){ TextMessage text = (TextMessage) msg; try {System.out.println(text.getText()+"恩，我收到了");} catch (JMSException e) {System.out.println("数据接收错误");} } }); Thread.sleep(10000); session.commit(); consumer.close(); session.close(); connection.close();}
?
?
