1 24 package soap; 25 26 import javax.jms.*; 27 import javax.naming.*; 28 29 31 public class SoapConsumer 32 { 33 static Context ictx = null; 34 35 public static void main(String [] args) throws Exception 36 { 37 System.out.println(); 38 System.out.println("Consumes messages on the queue and on the topic..."); 39 40 ictx = new InitialContext(); 41 ConnectionFactory cf = (ConnectionFactory) ictx.lookup("soapCf"); 42 Queue queue = (Queue) ictx.lookup("queue"); 43 Topic topic = (Topic) ictx.lookup("topic"); 44 ictx.close(); 45 46 Connection cnx = cf.createConnection(); 47 Session qSess = cnx.createSession(false, Session.AUTO_ACKNOWLEDGE); 48 Session tSess = cnx.createSession(false, Session.AUTO_ACKNOWLEDGE); 49 50 MessageConsumer qConsumer = qSess.createConsumer(queue); 51 MessageConsumer tConsumer = tSess.createConsumer(topic); 52 53 tConsumer.setMessageListener(new MsgListener()); 54 55 cnx.start(); 56 57 TextMessage msg; 58 59 for (int i = 0; i < 10; i++) { 60 msg = (TextMessage) qConsumer.receive(); 61 System.out.println("Message received from queue: " + msg.getText()); 62 } 63 64 System.in.read(); 65 cnx.close(); 66 } 67 } 68 69 class MsgListener implements MessageListener 70 { 71 public void onMessage(Message msg) 72 { 73 try { 74 if (msg instanceof TextMessage) 75 System.out.println("Message received from topic: " 76 +((TextMessage) msg).getText()); 77 } 78 catch (Exception exc) { 79 System.out.println("Exception in listener: " + exc); 80 } 81 } 82 } 83 | Popular Tags |