1 package Jt.examples.jms; 2 3 import Jt.*; 4 import Jt.jms.*; 5 import java.io.*; 6 7 9 public class JMSSubscriber { 10 11 12 13 15 public static void main(String [] args) { 16 17 JtFactory main = new JtFactory (); JtMessage msg; 19 String greeting; 20 String reply; 21 Jt.jms.JtJMSTopicAdapter jmsAdapter; 22 JtEcho echo = new JtEcho (); 23 JtKeyboard keyboard = new JtKeyboard (); 24 25 26 27 jmsAdapter = (Jt.jms.JtJMSTopicAdapter) main.createObject 28 ("Jt.jms.JtJMSTopicAdapter", "jmsAdapter"); 29 30 31 main.setValue (jmsAdapter, "subject", echo); 32 main.sendMessage (jmsAdapter, new JtMessage ("JtSTART_LISTENING")); 33 34 main.sendMessage (keyboard, new JtMessage ("JtACTIVATE")); 35 36 37 38 39 41 main.removeObject ("jmsAdapter"); 42 43 44 45 } 46 47 } 48 49 50 51 | Popular Tags |