JMS学习笔记 (queue的使用)2

3. 同步接收队列中的消息

package queue;

import javax.jms.*;
import javax.naming.*;
import java.util.Properties;
import java.io.*;

public class receive
{
??? public static void main(String args[]) throws Exception
??? {
??????? QueueReceiver receiver;
??????? TextMessage msg;
??????? Properties p = new Properties();
??????? FileInputStream f = new FileInputStream("D:\\resource\\jndi.properties");
??????? p.load(f);
??????? Context ctx = new InitialContext(p);
??????? QueueConnectionFactory qConFactory = (QueueConnectionFactory) ctx.lookup("ConnectionFactory");
??????? Queue messageQueue = (Queue) ctx.lookup("queue/bitsqueue");
??????? System.out.println(messageQueue);
??????? QueueConnection qCon = qConFactory.createQueueConnection();
??????? QueueSession session = qCon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
??????? qCon.start();
??????? receiver = session.createReceiver(messageQueue);
??????? msg = (TextMessage) receiver.receive();
??????? System.out.println(msg);
??? }
}

?