1 24 package topicTree; 25 26 import javax.jms.*; 27 import javax.naming.*; 28 29 32 public class Consumer 33 { 34 static Context ictx = null; 35 36 public static void main(String [] args) throws Exception 37 { 38 System.out.println(); 39 System.out.println("Listens to the topics..."); 40 41 ictx = new InitialContext(); 42 Topic news = (Topic) ictx.lookup("news"); 43 Topic business = (Topic) ictx.lookup("business"); 44 Topic sports = (Topic) ictx.lookup("sports"); 45 Topic tennis = (Topic) ictx.lookup("tennis"); 46 ConnectionFactory cf = (ConnectionFactory) ictx.lookup("cf"); 47 ictx.close(); 48 49 Connection cnx = cf.createConnection(); 50 Session sess = cnx.createSession(false, 51 javax.jms.Session.AUTO_ACKNOWLEDGE); 52 MessageConsumer newsConsumer = sess.createConsumer(news); 53 MessageConsumer businessConsumer = sess.createConsumer(business); 54 MessageConsumer sportsConsumer = sess.createConsumer(sports); 55 MessageConsumer tennisConsumer = sess.createConsumer(tennis); 56 57 newsConsumer.setMessageListener(new MsgListener("News reader got: ")); 58 businessConsumer.setMessageListener(new MsgListener("Business reader" 59 + " got: ")); 60 sportsConsumer.setMessageListener(new MsgListener("Sports reader got: ")); 61 tennisConsumer.setMessageListener(new MsgListener("Tennis reader got: ")); 62 63 cnx.start(); 64 65 System.in.read(); 66 67 cnx.close(); 68 69 System.out.println(); 70 System.out.println("Consumers closed."); 71 } 72 } 73 | Popular Tags |