JMS Consumer not receiving any messages.

[Jigar Naik]

Hi bellow is the code for JMS Consumer. I have tried to debug the code but the program is not calling onMessage() even though there are messages.

am i missing something ?

  
package org.icrm.cons;
 
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.ExceptionListener;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
 
import javax.jms.Session;
import javax.jms.TextMessage;
 
import org.apache.activemq.ActiveMQConnectionFactory;
 
public class JConsumer implements ExceptionListener,MessageListener{
public static void main(String[] args){
JConsumer consumer = new JConsumer();
System.out.println("here 1");
consumer.consumeMessage("MyQueue");
}
public void consumeMessage(String queueName){
try{
System.out.println("here 2");
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.start();
connection.setExceptionListener(this);
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(queueName);
MessageConsumer consumer = session.createConsumer(destination);

//ASync
consumer.setMessageListener(this);
//Sync
/*Message message = consumer.receive(1000);
TextMessage textMessage = (TextMessage)message;
String text = textMessage.getText();
System.out.println("Received : " + text);
*/

consumer.close();
session.close();
connection.close();
}catch(Exception e){
System.out.println("Caught: " + e);
e.printStackTrace();
}

}
 
public void onException(JMSException arg0) {
System.out.println("JMS Exception occured.  Shutting down client.");
}
 
public void onMessage(Message message) {
try{
TextMessage textMessage = (TextMessage)message;
String text = textMessage.getText();
System.out.println("Received: " + text);
}catch(JMSException e){
e.printStackTrace();
}
}
}
 

[Jigar Naik]

Hey,

I have commented the following line of code, and i received all the messages.

  
//consumer.close();
//session.close();
//connection.close();

but then when should i close the consumer, session and connection ???

[Scott Selikoff]

In a finally block, to guarantee they get closed.

[Jigar Naik]

all right.. thanks