Unable to consume message from jms queue more than once using jsf

[Jay Lim]

I am trying to create a jsf page which will connect to this managed bean when it wants to receive a message from the jms queue. In the JSF page, when the method #{review.getMessage()} was called, a message could successfully be retrieved from the queue. However, when i close the webpage and reopen again, to try to make a connection to the jms queue, i realized i was not able to receive the JMS message from the queue. I have to redeploy the Glassfish server, in order for the consumption of message to work again. While debugging, i realized the onMessage method was called during the first run only.

Thanks in advance for the help guys!

        package beans;
        
        import java.io.Serializable;
        import java.util.ArrayList;
        import java.util.HashMap;
        import java.util.logging.Level;
        import java.util.logging.Logger;
        import javax.annotation.Resource;
        import javax.enterprise.context.SessionScoped;
        import javax.faces.bean.ManagedBean;
        import javax.faces.context.FacesContext;
        import javax.jms.*;
        import javax.servlet.http.HttpSession;
    
        @ManagedBean(name = "review")
        @SessionScoped
        public class ReviewBean implements Serializable {
    
        @Resource(mappedName = "jms/q.reviewFactory")
        private ConnectionFactory queueFactory;
        @Resource(mappedName = "jms/q.review")
        private Queue queue;
        public String message;
    
        public String getMessage() {
            boolean flag = getMessageFromJMS();
            if (flag) {
                invalidateSession();
                return "display";
            } else {
                invalidateSession();
                return "blank";
            }
        }
    
        public void invalidateSession(){
            FacesContext context = FacesContext.getCurrentInstance();
            HttpSession session = (HttpSession) context.getExternalContext().getSession(false);
            session.invalidate();
        }
        
        public void setMessage(String message) {
            this.message = message;
        }
    
        /**
         * Creates a new instance of ReviewBean
         */
        public ReviewBean() {
            System.out.println("Initialize ReviewBean");
        }
    
        public boolean getMessageFromJMS() {
            Connection qConnection = null;
            try {
                qConnection = queueFactory.createConnection();
                Session session = qConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
                MessageConsumer consumer = session.createConsumer(queue);
                consumer.setMessageListener(new BillListener());
                qConnection.start();
            } catch (Exception ex) {
                Logger.getLogger(ReviewBean.class.getName()).log(Level.SEVERE, null, ex);
            } finally {
                if (qConnection != null) {
                    try {
                        qConnection.close();
                        return true;
                    } catch (JMSException ex) {
                        Logger.getLogger(ReviewBean.class.getName()).log(Level.SEVERE, null, ex);
                        return false;
                    }
                }
            }
            return false;
        }
    
        public class BillListener implements MessageListener {
    
            @Override
            public void onMessage(Message message) {
                try {
                    ObjectMessage msg = (ObjectMessage) message;
                    ArrayList list = (ArrayList) msg.getObject();
    
                    for (int i = 0; i < list.size(); i++) {
                        if (list.size() == 1 || i == (list.size() - 1)) {
                            HashMap<String, String> map = (HashMap) list.get(i);
                            System.out.println("Balance Due: " + map.get("balancedue"));
                            break;
                        }
                        HashMap<String, String> map = (HashMap) list.get(i);
                        System.out.println(map.get("postingdate"));
                        System.out.println(map.get("description"));
                        System.out.println(map.get("amount"));
                    }
                } catch (JMSException ex) {
                    Logger.getLogger(BillListener.class.getName()).log(Level.SEVERE, null, ex);
                }
            }
        }
    }
    
    
    
    <?xml version='1.0' encoding='UTF-8' ?>
    <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
    <html xmlns="http://www.w3.org/1999/xhtml"
          xmlns:h="http://java.sun.com/jsf/html">
        <h:head>
            <title>Facelet Title</title>
        </h:head>
        <h:body>
            Hello from Facelets
            <h:form> 
                <h:commandButton id="submit" value="Confirm" action="#{review.getMessage()}"/>
            </h:form>
        </h:body>
    </html>

[Rajit vreddi]

Each messge is processed/consumed only once.

[Jay Lim]

Yes, but it should work such that, everytime i click the button in the JSF page, i should create a new connection and consume a message if there is one in the queue. However, now it is not working that way. Every subsequent connection i made, the onMessage was not activated even when there is a message waiting in the queue.
I have to redeploy the application in order for the message to be consumed. How do i make the onMessage to work every time i hit the button in the JSF page?

[E Armitage]

You are manually triggering the receipt so why have a MessageListener if you're not receiving the messages asynchronously?
I'd expect that you would call the receive or receiveNoWait method here.

[Jay Lim]

Hey! That was awesome! I managed to receive the messages successfully whenever i click the button after using the receive() than onMessage().
I understand why receive will work, but i am also curious why the onMessage() method doesn't work? While implementing in application client, it works successfully whenever i run it.
Is it because the web takes a shorter time to load, thus the message does not call the onMessage method?

[E Armitage]

Jay Lim wrote:..
I understand why receive will work, but i am also curious why the onMessage() method doesn't work?..

Probably because you're inducing undefined behavior. The specs for setMessageListener says

The effect of calling MessageConsumer.setMessageListener while messages are being consumed by an existing listener or the consumer is being used to consume messages synchronously is undefined.

[Rajit vreddi]

your messagelistener behaving not properly or stop running after message is consumed.did you clean resources like session,queue and etc.. after finishing message process.