샘플 JMS 1.1 애플리케이션 클라이언트
JMS 1.1 애플리케이션 클라이언트를 처음 프로그래밍하는 경우 이 코드 예를 클라이언트 애플리케이션 개발을 위한 시작점으로 사용할 수 있습니다.
예
import java.util.Hashtable;
import javax.jms.JMSException;
import javax.naming.Context;
import javax.naming.*;
import javax.jms.*;
public class JMSppSampleClient
{
public static void main(String[] args)
throws JMSException, Exception
{
String messageID = null;
String outString = null;
String cfName = "jms/blueconfactory";
String qnameIn = "java:comp/env/jms/Q1";
String qnameOut = "jms/bluequename";
boolean verbose = false;
Session session = null;
Connection connection = null;
ConnectionFactory cf = null;
MessageProducer mp = null;
Destination destination = null;
try {
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY,
"com.ibm.websphere.naming.WsnInitialContextFactory");
env.put(Context.PROVIDER_URL, "iiop://localhost:2809");
Context initialContext = new InitialContext(env);
System.out.println("Getting Connection Factory");
cf= (ConnectionFactory)initialContext.lookup( cfName );
System.out.println("Getting Queue");
destination =(Destination)initialContext.lookup(qnameOut);
System.out.println("Getting Connection for Queue");
connection = cf.createConnection();
System.out.println("staring the connection");
connection.start();
System.out.println("creating session");
session = connection.createSession(false, 1);
System.out.println("creating messageProducer");
mp = session.createProducer(destination);
System.out.println("creating TextMessage");
TextMessage outMessage = session.createTextMessage("this is test application");
System.out.println("sending Message");
mp.send(outMessage);
mp.close();
session.close();
connection.close();
}
catch (Exception je) {}