sendrecvclient.java

jboss 的官方实例程序

package org.jboss.book.jms.ex1; 
import javax.jms.JMSException; 
import javax.jms.Message; 
import javax.jms.MessageListener;
 
import javax.jms.Queue; 
import javax.jms.QueueConnection; 
import javax.jms.QueueConnectionFactory; 
import javax.jms.QueueReceiver; 
import javax.jms.QueueSender; 
import javax.jms.QueueSession; 
import javax.jms.TextMessage; 
import javax.naming.InitialContext; 
import javax.naming.NamingException; 
import EDU.oswego.cs.dl.util.concurrent.CountDown; 
import org.apache.log4j.Logger; 
import org.jboss.util.ChapterExRepository;

 /**
  * A complete JMS client example program that sends a 
  * TextMessage to a Queue and asynchronously receives the 
  * message from the same Queue. 
  * 
  * @author [e-mail] 
  * @version $Revision: 1.1 $ 
  */ 

public class SendRecvClient { 
    static Logger log;
    static CountDown done = new CountDown(1);

    QueueConnection conn;
    QueueSession session;
    Queue que;

    public static class ExListener 
        implements MessageListener 
    { 
        public void onMessage(Message msg) { 
            done.release();
            TextMessage tm = (TextMessage) msg;
            try { 
                log.info("onMessage, recv text=" + tm.getText());
            } catch(Throwable t) { 
                t.printStackTrace();
            }
        } 
    }

    public void setupPTP() 
        throws JMSException, 
               NamingException 
    { 
        InitialContext iniCtx = new InitialContext();
 
        Object tmp = iniCtx.lookup("ConnectionFactory");
        QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
        conn = qcf.createQueueConnection();
        que = (Queue) iniCtx.lookup("queue/testQueue");
        session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
        conn.start();
    } 

    public void sendRecvAsync(String text) 
        throws JMSException, 
               NamingException 
    { 
        log.info("Begin sendRecvAsync");
        // Setup the PTP connection, session 
        
        setupPTP();
        
        // Set the async listener 
        QueueReceiver recv = session.createReceiver(que);
        
        recv.setMessageListener(new ExListener());
        
        // Send a text msg 
        QueueSender send = session.createSender(que);
        
        TextMessage tm = session.createTextMessage(text);
        send.send(tm);
        log.info("sendRecvAsync, sent text=" + tm.getText());
        send.close();
        log.info("End sendRecvAsync");
    } 

    public void stop() 
        throws JMSException 
    { 
        conn.stop();
        session.close();
        conn.close();
    } 

    public static void main(String args[]) 
        throws Exception 
    { 
        ChapterExRepository.init(SendRecvClient.class);
        log = Logger.getLogger("SendRecvClient");
        log.info("Begin SendRecvClient, now=" + System.currentTimeMillis());
        SendRecvClient client = new SendRecvClient();
        client.sendRecvAsync("A text msg");
        client.done.acquire();
        client.stop();
        log.info("End SendRecvClient");
        System.exit(0);
    }
}