public class MessageQueueSender {
 public static void main(String[] args) {
  if( args.length != 1 ) {
   System.out.println("Usage : java MessageQueueSender [Message]");
   System.exit(0);
  }

  try {
    // HTTP protocol을 이용하여 WegLogic에 접근하는 것이 아니기 때문에
    // java application에서 WegLogic을 사용하기 위해 설정하는 부분
   Properties p = new Properties();
   p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
   p.put(Context.PROVIDER_URL, "t3://localhost:7001");

   Context ctx = new InitialContext(p);

   QueueConnectionFactory factory = (QueueConnectionFactory)ctx.lookup("weblogic.jms.ConnectionFactory");

   Queue queue = (Queue)ctx.lookup("jmsqueue");
   QueueConnection con = factory.createQueueConnection();
   QueueSession session = con.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
   QueueSender qsender = session.createSender(queue);
   TextMessage message = session.createTextMessage();
   message.setText(args[0]);
   qsender.send(message);
   qsender.send(session.createMessage());
   con.close();
  } catch(Exception e) {
   e.printStackTrace();
  }
 }
}

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

public class MessageQueueReceiver {
 public static void main(String[] args) {
   Queue queue = null;
   QueueConnection con = null;
   QueueSession session = null;
   QueueReceiver qreceiver = null;
   
  try {
   Properties p = new Properties();
   p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
   p.put(Context.PROVIDER_URL, "t3://localhost:7001");

   Context ctx = new InitialContext(p);

   QueueConnectionFactory factory = (QueueConnectionFactory)ctx.lookup("weblogic.jms.ConnectionFactory");

   queue = (Queue)ctx.lookup("jmsqueue");
   con = factory.createQueueConnection();
   session = con.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
   qreceiver = session.createReceiver(queue);
   
   con.start();
   
   while(true) {
    Message msg = qreceiver.receive(1);
   
    if( msg != null ) {
     if( msg instanceof TextMessage ) {
      TextMessage tmpMsg = (TextMessage)msg;
      System.out.println("읽어온 메시지 : " + tmpMsg.getText());

      if( "exit".equals(tmpMsg.getText()) ) {
       break;
      }
     }
    } else {
     Thread.sleep(500);
    }
   }
  } catch(Exception e) {
   e.printStackTrace();
  } finally {
   try {
    con.close();
   } catch(Exception e) {
   }
  }
 }
}

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

public class MessageTopicPublisher {
 public static void main(String[] args) {
  BufferedReader br = null;

  try {
   Properties p = new Properties();
   p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
   p.put(Context.PROVIDER_URL, "t3://localhost:7001");

   Context ctx = new InitialContext(p);
   TopicConnectionFactory factory = (TopicConnectionFactory)ctx.lookup("weblogic.jms.ConnectionFactory");

   Topic topic = (Topic)ctx.lookup("jmstopic");
   TopicConnection con = factory.createTopicConnection();
   TopicSession session = con.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
   TopicPublisher publisher = session.createPublisher(topic);

   String line = null;
   br = new BufferedReader(new InputStreamReader(System.in));

   while( (line = br.readLine()) != null ) {
    TextMessage message = session.createTextMessage();
    message.setText(line);
    publisher.publish(message);

    if( "exit".equals(line) ) {
     break;
    }

    message = null;
   }

   con.close();

  } catch(Exception e) {
   e.printStackTrace();
  }
 }
}

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

public class MessageTopicSubscriber {
 public static void main(String[] args) {
  BufferedReader br = null;

  try {
   Properties p = new Properties();
   p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
   p.put(Context.PROVIDER_URL, "t3://localhost:7001");

   Context ctx = new InitialContext(p);
   TopicConnectionFactory factory = (TopicConnectionFactory)ctx.lookup("weblogic.jms.ConnectionFactory");

   Topic topic = (Topic)ctx.lookup("jmstopic");
   TopicConnection con = factory.createTopicConnection();
   TopicSession session = con.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
   TopicSubscriber subscriber = session.createSubscriber(topic);
   subscriber.setMessageListener(new MessageListener() {
    public void onMessage(Message message) {
     try {
      if( message instanceof TextMessage) {
       TextMessage m = (TextMessage)message;
       System.out.println("구독 내용 > " + m.getText());
      }
     } catch(Exception e) {
      e.printStackTrace();
     }
    }

   });

   con.start();
   while(true) {
    char c = (char)System.in.read();
    if( c == 'q') break;
   }
   con.close();

  } catch(Exception e) {
   e.printStackTrace();
  }
 }
}

package kr.co.ejb.examples;

/**
 * Remote Interface
 *
 * Client가 호출할 원격 인터페이스
 * Client가 호출할 메소드만 정의함
 *
 * @author Lucky
 */

import java.rmi.RemoteException;
import javax.ejb.EJBObject;

public interface HelloWorld extends EJBObject {
 public String helloWorld() throws RemoteException;
 public String hello(String param) throws RemoteException;
 public String getTime() throws RemoteException;
}

package kr.co.ejb.examples;

/**
 * Bean Class
 */

import javax.ejb.SessionBean;
import javax.ejb.SessionContext;

public class HelloWorldBean implements SessionBean {
 private SessionContext ctx;

 public void setSessionContext(SessionContext c) {
  ctx = c;
 }

 public String helloWorld() {
  return "Hello World";
 }

 public String hello(String param) {
  return "Hello " + param;
 }

 public String getTime() {
  return (new java.util.Date().toString());
 }

 public void ejbCreate() {}
 public void ejbRemove() {}
 public void ejbActivate() {}
 public void ejbPassivate() {}
}

package kr.co.ejb.examples;

/**
 * Home Interface
 *
 * Client가 EJB를 생성시킬 때 사용하는 메소드 정의
 *
 *
 * @author Lucky
 */

import java.rmi.RemoteException;
import javax.ejb.CreateException;
import javax.ejb.EJBHome;

public interface HelloWorldHome extends EJBHome {
 public HelloWorld create() throws CreateException, RemoteException;
}

class Test {
 public static void swap(int x, int y) {
  int temp;
  temp = y;
  y = x;
  x = temp;
 }

 public static void swap(Number n) {
  int temp;
  temp = n.x;
  n.x = n.y;
  n.y = temp;
 }

 public static void objRef(Number n) {
  n = null;
 }

 public static void main(String[] args) {
  int a = 10;
  int b = 20;

  System.out.println(a + ", " + b);
  swap(a, b);
  System.out.println(a + ", " + b);

  String str1 = "1234";
  String str2 = "1234";
  Integer int3 = new Integer(1234);
  String str4 = new String("1234");

  System.out.println(str1 == str2);
  System.out.println(str1.equals(int3));
  System.out.println(str1 == str4);
  System.out.println(str1.equals(str4));

  Number n = new Number();
  n.x = 10;
  n.y = 20;

  System.out.println(n.x + ", " + n.y);
  swap(n);
  System.out.println(n.x + ", " + n.y);
  objRef(n);
  System.out.println(n.x + ", " + n.y);
 }
}

class Number {
 int x;
 int y;
}

 <servlet>
  <servlet-name>Counter</servlet-name>
  <servlet-class>examples.CounterServlet</servlet-class>
 </servlet>

 <servlet-mapping>
  <servlet-name>HelloWorld</servlet-name>
  <url-pattern>/hello</url-pattern>
 </servlet-mapping>

 <servlet-mapping>
  <servlet-name>Counter</servlet-name>
  <url-pattern>/counter</url-pattern>
 </servlet-mapping>