[jboss-user] [Beginner's Corner] - AS 7.1.1 send/receive a JMS message in Servlet question

[Michael Justin]

Michael Justin [https://community.jboss.org/people/mjustin] created the discussion

"AS 7.1.1 send/receive a JMS message in Servlet question"

To view the discussion, visit: https://community.jboss.org/message/728702#728702

--------------------------------------------------------------
Hello,

I am trying to build a simple JMS produce / consume example in a Servlet. The full source code is below.

The servlet uses a resource annotation to inject the JMS destination which is configured in standalone-full.xml, and I also can verify that the destination exists (in the admin interface) and user and password are valid. The produce / consume methods complete without any errors, but the web admin interface does not show any messages. I tried to use persistent messages but it did not help. I will also check out the examples in the source distribution, and come back if I found the reason.


package servlet;

import java.io.IOException;
import java.io.Writer;
import java.util.logging.Logger;

import javax.annotation.Resource;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet(name = "My Servlet", urlPatterns = { "/ms" })
public class MyServlet extends HttpServlet {
    private static final long serialVersionUID = 1L;

    @Resource(mappedName = "java:/ConnectionFactory")
    ConnectionFactory factory;

    private static final Logger log = Logger.getLogger("");
    private static final String username = "guest";
    private static final String password = "secret";
    private static final String destination = "ExampleTopic";

    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        produce();
        consume();
    }

    private void produce() {
        try {
            Connection conn = factory.createConnection(username, password);
            Session session = conn.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageProducer prod = session.createProducer(session
                    .createTopic(destination));
            prod.setDeliveryMode(DeliveryMode.PERSISTENT);
            conn.start();
            Message msg = session.createTextMessage("hello");
            prod.send(msg);
            conn.close();
        } catch (JMSException e) {
            log.info(e.getMessage());
        }
    }

    private void consume() {
        try {
            Connection conn = factory.createConnection(username, password);
            Session session = conn.createSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            MessageConsumer cons = session.createConsumer(session
                    .createTopic(destination));
            conn.start();
            Message msg = cons.receive(1000);
            if (msg == null) {
                log.info("received no message");
            } else {
                TextMessage t = (TextMessage) msg;
                log.info(t.getText());
            }
            conn.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }

}
--------------------------------------------------------------

Reply to this message by going to Community
[https://community.jboss.org/message/728702#728702]

Start a new discussion in Beginner's Corner at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&containerType=14&container=2075]

-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/jboss-user/attachments/20120406/b1af0449/attachment.html