setMessageListener jms method in Websphere Application server generates javax.jms.IllegalStateException: Method setMessageListener not permitted

Question

I am using Websphere Application Server 7.x version.

I want to read the messages buffered in MQ with the help of JMS API as given below. I referred from link1, link2

    @Resource(lookup = "jms/ConnectionFactory")
    private static ConnectionFactory connectionFactory;

    @Resource(lookup = "jms/Queue")
    private static Queue queue;

    public void readMessagesFromQueue() {
        try {

          Connection connection = connectionFactory.createConnection();
          Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
          MessageConsumer consumer = session.createConsumer(queue);

          MyListener myListener = new MyListener();
          consumer.setMessageListener(myListener); // Error here
          connection.start();
         } catch (JMSException e) {
           throw new RuntimeException(e);
         }
    }

MyListener class:

public class MyListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        try {
           String text=((TextMessage)message).getText();
           System.out.println(text);
         }
         catch (JMSException e) {
            throw new RuntimeException(e);
         }
    }
}

During the run time I am getting Exception:

javax.jms.IllegalStateException: Method setMessageListener not permitted

I could see in the link that the method setMessageListener for asynchronous messaging, it is forbidden to use this method in a WebSphere Application Server.

Question 1:

Can't this setMessageListener method be used in WAS?
If not, what is the work around to achieve the above required functionality?

Question 2:

I can explain the need in other words:
The JMS listner should not recive the messages as soon as the message arrived in the the queue. But I want the listener to listen only during the time I require.
I tried the approach which I mentioned above. But I got blocked because of the exception.

Any other way to achieve this?

If you want to asynchronously receive messages then create MDB, otherwise call consumer.receive() method to read messages. — Gas
@Gas, I can use MDB to asynchronously receive messages. But I also want the MDB to inactive during sometime and make it active during sometime. — Alagammal P

titou10 titou10 · Accepted Answer · 2017-04-07T01:48:03

This is not a WebSphere problem.
In short, the JMS spec does not allow you to use this feature in a JEE Container: Check the API here :

void setMessageListener(MessageListener listener)
             throws JMSException

   Sets the MessageConsumer's MessageListener.
   {...}
   This method must not be used in a Java EE web or EJB application. Doing so may cause a JMSException to be thrown though this is not guaranteed.

setMessageListener jms method in Websphere Application server generates javax.jms.IllegalStateException: Method setMessageListener not permitted

3 Answers