messagesender.java

java的一系列产品中包括jsme,jmse,j2ee,本文件提供j2ee实现的源代码.

package jmsejb;

import java.util.Properties;
import javax.rmi.PortableRemoteObject;
import javax.naming.InitialContext;
import javax.naming.Context;
import javax.naming.NamingException;

import javax.jms.*;

public final class MessageSender{

  private static QueueConnection queueConnection = null;
  private static QueueSender queueSender         = null;
  private static QueueSession queueSession       = null;
  private static Queue queue                     = null;
  private static TextMessage msg                 = null;
  private static final String url  = "t3://localhost:7001";
      
  public static void main(String[] argv) throws Exception
  {
    try {
      Properties env = new Properties();
      env.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory");
      env.put(Context.PROVIDER_URL, url);
      
      Context ctx = new InitialContext(env);
      QueueConnectionFactory factory = (QueueConnectionFactory)
        ctx.lookup("weblogic.jms.ConnectionFactory");

      queueConnection = factory.createQueueConnection();

      // Create a non-transacted JMS Session
      queueSession = 
        queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
    
      queue = (Queue) ctx.lookup("MessageQueue");
      queueSender = queueSession.createSender(queue);
      msg = queueSession.createTextMessage();
      queueConnection.start();

    } catch (Exception e) {
      System.err.println("Error while attempting to connect to the "+
        "server and lookup the JMS QueueConnectionFactory.");      
    }

    for (int i=0; i<5; i++) {
      send("Message: "+i);
    }
    kill();
  }
  
  public static void send(String message) throws JMSException{
    try {
      msg.setText(message);
      queueSender.send(msg);
    } catch (JMSException e) {
      System.err.println("Exception raised while sending to queue: "+
        "MessageQueue");      
    }
  }

  public static void kill() throws JMSException{
    try {
      queueSender.close();
      queueSession.close();
      queueConnection.close();
    } catch (JMSException e) {
      System.err.println("Exception raised while closing JMS resources.");
    }
  }
}