1 24 package topicTree; 25 26 import javax.jms.*; 27 import javax.naming.*; 28 29 32 public class Producer 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("Produces messages on the various topics..."); 40 41 ictx = new InitialContext(); 42 Topic newsT = (Topic) ictx.lookup("news"); 43 Topic businessT = (Topic) ictx.lookup("business"); 44 Topic sportsT = (Topic) ictx.lookup("sports"); 45 Topic tennisT = (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(true, 0); 51 MessageProducer producer = sess.createProducer(null); 52 53 TextMessage msg = sess.createTextMessage(); 54 55 msg.setText("News!"); 56 producer.send(newsT, msg); 57 msg.setText("Business!"); 58 producer.send(businessT, msg); 59 msg.setText("Sports!"); 60 producer.send(sportsT, msg); 61 msg.setText("Tennis!"); 62 producer.send(tennisT, msg); 63 64 sess.commit(); 65 cnx.close(); 66 } 67 } 68 | Popular Tags |