jmstestclient.java~1~

100多M的J2EE培训内容

package userjmssesenbdb;

import java.util.*;
import javax.jms.*;
import javax.naming.*;

public class JMSTestClient {
  public JMSTestClient() {
  }

  public final static String
      JNDI_FACTORY = "weblogic.jndi.WLInitialContextFactory";
  public final static String URL = "t3://192.168.0.100:7001";
  private static final String QUEUE_CONNECTION_FACTORY =
      "DemoJMSConnectionFactory";
  private static final String QUEUE = "DemoJMSQueue";
  private static InitialContext getInitialContext(String url) throws
      NamingException {
    Hashtable env = new Hashtable();
    env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
    env.put(Context.PROVIDER_URL, url);
    return new InitialContext(env);
  }

  public static void main(String[] args) throws Exception {
    Context ctx = getInitialContext(URL);
    QueueConnectionFactory qConnFact =
        (QueueConnectionFactory) ctx.lookup(QUEUE_CONNECTION_FACTORY);
    QueueConnection qConn = qConnFact.createQueueConnection();
    QueueSession qSess = qConn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
    Queue q = (Queue) ctx.lookup(QUEUE);
    System.out.println(q);

    QueueSender qSend = qSess.createSender(q);
    TextMessage txtMsg = qSess.createTextMessage("c");
    System.out.println("Sending a message to queue");
    qSend.send(txtMsg);
//---------------------------------------------------------//
    txtMsg = qSess.createTextMessage("a");
    System.out.println("Sending a message to queue");
    qSend.send(txtMsg);
//---------------------------------------------------------//
    qConn.close();
    System.exit(0);
  }

}