1 23 package bridge; 24 25 import javax.jms.*; 26 27 30 public class BridgeSubscriber { 31 public static void main(String [] args) throws Exception { 32 javax.naming.Context jndiCtx = new javax.naming.InitialContext (); 33 Destination joramDest = (Destination) jndiCtx.lookup("joramTopic"); 34 ConnectionFactory joramCF = (ConnectionFactory) jndiCtx.lookup("joramCF"); 35 jndiCtx.close(); 36 37 Connection joramCnx = joramCF.createConnection(); 38 Session joramSess = joramCnx.createSession(false, Session.AUTO_ACKNOWLEDGE); 39 MessageConsumer joramCons = joramSess.createConsumer(joramDest); 40 joramCons.setMessageListener(new MsgListener("topic joram")); 41 joramCnx.start(); 42 43 System.in.read(); 44 45 joramCnx.close(); 46 } 47 } 48 | Popular Tags |