jmssubscriber.java

来自「Java Pattern Oriented Framework (Jt) 是为了」· Java 代码 · 共 52 行

package Jt.examples.jms;

import Jt.*;
import Jt.jms.JtJMSAdapter;
import Jt.jms.JtJMSTopicAdapter;


//Demonstrates the use of JtJMSTopicAdapter (JMS publish/subscriber adapter)

public class JMSSubscriber {



    // Test program

    public static void main(String[] args) {

        JtFactory main = new JtFactory ();  // Jt Factory
        //JtMessage msg;
        //String greeting;
        //String reply;
        JtJMSTopicAdapter jmsAdapter;
        JtEcho echo = new JtEcho ();
        JtKeyboard keyboard = new JtKeyboard ();



        jmsAdapter = (JtJMSTopicAdapter) main.createObject 
        (JtJMSTopicAdapter.JtCLASS_NAME, "jmsAdapter");


        main.setValue (jmsAdapter, "subject", echo);
        main.sendMessage (jmsAdapter, new JtMessage (JtJMSAdapter.JtSTART_LISTENING));

        main.sendMessage (keyboard, new JtMessage (JtObject.JtACTIVATE));




        // Remove jmsAdapter

        main.removeObject ("jmsAdapter");



    }

}