jmsreceiver.java

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

package Jt.examples.jms;

import Jt.*;
import Jt.jms.JtJMSAdapter;
import Jt.jms.JtJMSQueueAdapter;



//Demonstrates the use of JtJMSQueueAdapter (synchronous mode).
//Use the adapter  to send messages to the 
//JMS queue.

public class JMSReceiver  {


    // Test program (JMSQueue adapter)

    public static void main(String[] args) {

        JtFactory main = new JtFactory ();  // Jt Factory
        JtMessage msg;
        //String greeting;
        //String reply;
        JtJMSQueueAdapter jmsAdapter;


        // Create the JMS adapter (point-to-point)

        jmsAdapter = (Jt.jms.JtJMSQueueAdapter) main.createObject 
        (JtJMSQueueAdapter.JtCLASS_NAME, "jmsAdapter");


        // Receive all the messages (Jt messages)

        for (;;) {

            msg = (JtMessage) main.sendMessage (jmsAdapter, new JtMessage (JtJMSAdapter.JtRECEIVE));

            if (msg == null) {
                System.out.println ("no more messages");
                break;
            } 

            System.out.println ("msgId:" + msg.getMsgId ());

        }


        // Remove jmsAdapter

        main.removeObject ("jmsAdapter");



    }

}