Message is created but not received by the receiver

Vidya Moorthy

Ranch Hand

Posts: 57

posted 8 years ago

Hi
I am trying to create a sender JSP page using JMS and it creates a text message "Update" if the request attribute is "prodRequest". If not, then a message with the shopping cart contents are sent to the Queue. I can see that the message is getting created but it is not sent to the queue. Could you please help me find my mistake!

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
 
<HTML>
<HEAD>
<%@ page language="java" contentType="text/html; charset=ISO-8859-1"
pageEncoding="ISO-8859-1"import= "javax.servlet.*,
javax.jms.*,
javax.naming.Context,
                                javax.naming.InitialContext,
                                javax.naming.NamingException,
com.WebShop.Business.*,
com.WebShop.Data.*"
%>
 
<META http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<META name="GENERATOR" content="IBM Software Development Platform">
<META http-equiv="Content-Style-Type" content="text/css">
 
<TITLE>QueueSender.jsp</TITLE>
</HEAD>
<BODY>
<P><%String                  queueName = null;
        Context                 jndiContext = null;
        QueueConnectionFactory  queueConnectionFactory = null;
        QueueConnection         queueConnection = null;
        QueueSession            queueSession = null;
        Queue                   queue = null;
        QueueSender             queueSender = null;
        TextMessage             message = null;
        final int               NUM_MSGS;
        
        
        queueName = "jms/qd";
        System.out.println("Queue name is " + queueName);
        
        
        
        try {
            jndiContext = new InitialContext();
        } catch (NamingException e) {
            System.out.println("Could not create JNDI API " +
                "context: " + e.toString());
            System.exit(1);
        }
        
       
        try {
            queueConnectionFactory = (QueueConnectionFactory)
                jndiContext.lookup("jms/qcf");
            queue = (Queue) jndiContext.lookup(queueName);
        } catch (NamingException e) {
            System.out.println("JNDI API lookup failed: " + 
                e.toString());
            System.exit(1);
        }
try{
 
        
            queueConnection = 
                queueConnectionFactory.createQueueConnection();
            queueSession = 
                queueConnection.createQueueSession(false, 
                    Session.AUTO_ACKNOWLEDGE);
            
TextMessage msg = null;
String prodRequest = (String)request.getAttribute("prodRequest");
System.out.println("Attribute: " + prodRequest);
if(prodRequest.equals("prodRequest")){
msg = queueSession.createTextMessage("Update");
System.out.println("Creating message: " + msg);
}
else{
ServletContext sc = this.getServletContext();

Invoice invoice = (Invoice) sc.getAttribute("invoice");

System.out.println("Invoice Number: " + invoice.getInvoiceNumber());
System.out.println("Invoice Total: " + invoice.getInvoiceTotal());

msg = queueSession.createTextMessage(invoice.getInvoiceNumber()+"," + invoice.getInvoiceTotal());
System.out.println("Creating message: " + msg);
}

QueueSender sender = queueSession.createSender(queue);
sender.send(msg);
} catch (JMSException e) {
            System.out.println("Exception occurred: " + 
                e.toString());
        } finally {
            if (queueConnection != null) {
                try {
                    queueConnection.close();
                } catch (JMSException e) {}
            }
 
        
        }%>

</P>
</BODY>
</HTML>

I'll post the code for the queue receiver program if somebody wants to check if that has errors in it!
Thanks in advance
Vidya

Amit M Tank

Ranch Hand

Posts: 257

posted 8 years ago

How do you know that your messages are not posted to the Queue? Do you have a monitoring tool to see if there are messages in the queue?

What output do you see in the server logs? Does your JVM (Server) terminate when you run your program(JSP)?

Amit Tank
Linked In

Vidya Moorthy

Ranch Hand

Posts: 57

posted 8 years ago

First of all, thanks for your response. Second of all, sorry for the delay in posting the answers to your questions.
How do you know that your messages are not posted to the Queue?
-->The messages seem to be posted to the queue
Do you have a monitoring tool to see if there are messages in the queue?
-->I have the MQ series explorer

What output do you see in the server logs? Does your JVM (Server) terminate when you run your program(JSP)?
-->The statements which I print in the System.out are printed to the server log. The JVM doesn't terminate when I run the JSP.
I have one more question for you. Is it possible to write this queue sender and receiver in a Java program. How do I call that program from a jsp page?
Thanks
Vidya

Amit M Tank

Ranch Hand

Posts: 257

posted 8 years ago

-->I have the MQ series explorer

So you must be able to see if the messages are there in the Queue.

-->The statements which I print in the System.out are printed to the server log. The JVM doesn't terminate when I run the JSP.
I have one more question for you. Is it possible to write this queue sender and receiver in a Java program. How do I call that program from a jsp page?

I asked that question because I saw in your code. I guess you should remove that from your code as it will bring down the entire server in case of an Exception.

yes you can write the Sender and receiver in a java program and call that program from your JSP file. You just need to import those classes (sender and receiver) in the JSP and call the appropriate method in the scriplet. However, using scriplet is an old way of doing stuff in JSP, but if you are just working out examples then it is okay to use scriplets in JSP.

Amit Tank
Linked In

It is sorta covered in the JavaRanch Style Guide.

Message is created but not received by the receiver

Similar Threads