Masoud Kalali's Blog

May 2006 Archives

Step by Step toward a jms sample in NetBeans and yes GlassFish. part 2 : Remote Client

...
  Context ctx = new InitialContext();
...

• provider url , for glassfish in iiop format it is : iiop://127.0.0.1:3700
We can use a key like Context.PROVIDER_URL to put its value into hashtable , also we may use java.naming.provider.url String to put value of this parameter into HashTable . this parameter is vendor dependent.

• initial context factory , for glassfish it is : com.sun.appserv.naming.S1ASCtxFactory
This is another important parameter that we must set before we can access a JNDI Tree , indeed it is totaly vendor dependent because each vendor has its own implementation for its JNDI access. This factory will create the context object along with the url that you put into the hashtable. we may use Context.INITIAL_CONTEXT_FACTORY or "java.naming.factory.initial" string as a key to put this value into the hashtable

• glassfish_home/lib/appserv-rt.jar
• glassfish_home/lib/javaee.jar
• glassfish_home/lib/install/applications/jmsra/jmsra.jar
• glassfish_home/lib/install/applications/jmsra/imqbroker.jar
• glassfish_home/imq/lib/imq.jar
• glassfish_home/lib/appserv-admin.jar
• glassfish_home/imq/lib/jms.jar

public class JmsClient {
    Context ctx;
    public JmsClient() {
        Hashtable properties = new Hashtable(2);
        properties.put(Context.PROVIDER_URL,"iiop://127.0.0.1:3700");
        properties.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.appserv.naming.S1ASCtxFactory");
        try {
            ctx = new InitialContext(properties);
        } catch (NamingException ex) {
            ex.printStackTrace();
        }
    }
   public Object lookup(String name){
        try {
            return ctx.lookup(name);
        } catch (NamingException ex) {
            ex.printStackTrace();
        }
        return null;
    }

    public static void main(String[] args) {
        JmsClient client = new JmsClient();
        try{
            ConnectionFactory     connectionFactory = (ConnectionFactory)client.lookup("jms/tConnectionFactory");
            Queue     queue = (Queue)client.lookup("jms/tQueue");
            javax.jms.Connection  connection = connectionFactory.createConnection();
            javax.jms.Session        session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
            MessageProducer messageProducer = session.createProducer(queue);
            for(int i=0;i<5;i++) {
                TextMessage message = session.createTextMessage("It is a message from main class "+  ": "+ i);
                System.out.println( "It come from main class:"+ message.getText());
                messageProducer.send(message);
            }
        } catch(Exception ex){
            ex.printStackTrace();
        }
    }
}

• we create a ConnectionFactory by looking it up in the jndi by using our context and dummy lookup(...) method.
• we create a Queue by looking it up in the jndi by using our context and dummy lookup(...) method.
• Then we create a connection using that ConnectionFactory
• we obtain a Session (jms Session) using our connection
• we made the messageproducer which is our tools to send message to that Queue ,
• in a loop we create and sent 5 text message to the queue.

GlassFish is Open source , but how much Open it is ?

Step by Step toward a jms sample in NetBeans and yes GlassFish

• A JMS implementation that is configured with our server , it can be done using embedded servers that are shipped with application servers or using remote / local MQ servers.
  GlassFish uses Sun message Queue , which is going to be available under the same license that GlassFish is provided. You can find more information about open source version at : http://mq.dev.java.net
• You also need to setup a Queue and a connection factory in your application server.*
• you should Create an MDB , and then implement the onMessage() method in way that you like.

• use GlassFish server web based administration console
• use GlassFish command line console
• using NetBeans 5.5 , yes NetBeans provide you some wizard thingy to make JMS / JDBC resources from withing NetBeans and then registering them to Application server.

• Run The IDE and go to runtime tab , expand server node and start the GlassFish instance.
• right click on GlassFish node and select view admin console
• login to admin console ,In left side navigation panel , expand the resources and expand JMS resources
• click on connection factories and from main frame click on new button , fill in the values as following ones
• JNDI Name: jms/tConnectionFactory
• Type: javax.jmsConnectionFactory **
• Description: some description here
• give it a name like : tConnectionFactory
• Click OK button
** in JMS 1.1 we can use same factory for both publish/subscribe and point-to-point messaging
• now we need to create a queue to be our messages destination, click on destination resources from main frame click on new and fill in the values as following ones
• JNDI Name: jms/tQueue
• Type: javax.JMS.Queue
• Description: some description here
• give it a name like : tQueue
• Click Save button

• EJB Name : TMDB
• package : mdbs
• Mapped Name : jms/tQueue***

  @Resource
    private MessageDrivenContext mdc;
    public void onMessage(Message message) {
     
        TextMessage msg = null;
        try {
            if (message instanceof TextMessage) {
                msg = (TextMessage) message;
System.out.println("A Message received in TMDB: " +
                        msg.getText());
            } else {
               System.out.println("Message of wrong type: " +
                        message.getClass().getName());
                
            }
        } catch (JMSException e) {
            e.printStackTrace();
            mdc.setRollbackOnly();
        } catch (Throwable te) {
            te.printStackTrace();
        }
    }

<%@page contentType="text/html"%>

<%@page pageEncoding="UTF-8"%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"
   "http://www.w3.org/TR/html4/loose.dtd">
<html>
    <head>

        <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
        <title>JSP Page</title>

    </head>
    <body>
<center>        
<form action="sendMessage">
            <table  cellspacing="20" >

                <tbody>
                    <tr>
                        <td>Enter some message: </td>
                        <td><input type="text" name="message" value="Enter your message here" width="30" /></td>

                    </tr>
                </tbody>
            </table>
            
                <input type="submit" value="Send The message" name="send" />

            </center>
        </form>
    </body>
</html>

1. Right click on web application node and select New > Servlet...
2. change its Name to sendMessage give it a package name and click finish
3. change the processRequest(..) method body as following list

 protected void processRequest(HttpServletRequest request, HttpServletResponse response)
    throws ServletException, IOException {
        response.setContentType("text/html;charset=UTF-8");
        PrintWriter out = response.getWriter();
        //start the jms stuff

        try{
            Context ctx = new InitialContext();
            ConnectionFactory     connectionFactory = (ConnectionFactory)ctx.lookup("jms/tConnectionFactory");
            Queue     queue = (Queue)ctx.lookup("jms/tQueue");
            javax.jms.Connection  connection = connectionFactory.createConnection();
            javax.jms.Session        session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
            MessageProducer messageProducer = session.createProducer(queue);
            TextMessage message = session.createTextMessage();
            message.setText(request.getParameter("message"));
            System.out.println( "It come from Servlet:"+ message.getText());
            messageProducer.send(message);

//message sent , it was all
            
            //show what we have done in this servlet
            out.println("<html>");
            out.println("<head>");
            out.println("<title>Servlet sendMessage</title>");
            out.println("</head>");
            out.println("<body>");
            out.println("<center>");
            out.print("Servlet Send this message <h2>"+request.getParameter("message") + "</h2>  to this Queue : <h2>"+queue.getQueueName()+"</h2>");
            out.println("</center>");
            out.println("</body>");
            out.println("</html>");
            
        } catch(Exception ex){
            ex.printStackTrace();
        }
        
        out.close();
    }

This work is licensed under a Creative Commons License.