1 24 package perfs; 25 26 import javax.jms.*; 27 import javax.naming.*; 28 29 public class PerfsReceiver 30 { 31 static Context ictx = null; 32 33 public static void main(String [] args) throws Exception 34 { 35 ictx = new InitialContext(); 36 Queue queue = (Queue) ictx.lookup("queue"); 37 ConnectionFactory cf = (ConnectionFactory) ictx.lookup("cf"); 38 ictx.close(); 39 40 Connection cnx = cf.createConnection(); 41 Session sess = cnx.createSession(false, Session.AUTO_ACKNOWLEDGE); 42 MessageConsumer cons = sess.createConsumer(queue); 43 44 MessageListener listener = new MsgListener(100); 45 cons.setMessageListener(listener); 46 47 cnx.start(); 48 49 synchronized(listener) { 50 listener.wait(); 51 } 52 53 cnx.close(); 54 55 System.out.println("Consumer terminated"); 56 } 57 } 58 | Popular Tags |