JMS Consumer ends even after implementing MessageListener interface.

[Jigar Naik]

Hi,

I have written below consumer which implements MessageListener interface. when i run this program as java application my program ends without throwing any exception. The program should be continuously running right ? as i have implemented MessageListener interface so that whenever message comes in onMessage(Message message) method will get called.

package com.consumer;

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 MyConsumer {

	private static ActiveMQConnectionFactory connectionFactory;
	private static Connection connection;
	private static Session session;
	private static Destination destination;
	private static boolean transacted = false;
	private static MessageConsumer consumer;

	public static void setUp() throws JMSException {
		connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnectionFactory.DEFAULT_BROKER_URL);
		connection = connectionFactory.createConnection();
		connection.start();
		session = connection.createSession(transacted, Session.AUTO_ACKNOWLEDGE);
		destination = session.createQueue("JN_11102010");
		consumer = session.createConsumer(destination);
		System.out.println("Consumer started successfully");
	}

	public static String receiveMessage() throws JMSException {

		/**
		 * Comment the below three lines if you want synchronous consumer.
		 */
		 MyConsumerListener myConsumerListener = new MyConsumerListener();
		 consumer.setMessageListener(myConsumerListener);
		 connection.setExceptionListener(myConsumerListener);
		 
		/**
		 * Uncomment the below code if you want to receive message
		 * synchronously.
		 */
	
		/*
		Message message = consumer.receive(1000);
		if (message instanceof TextMessage) {
			TextMessage textMessage = (TextMessage) message;
			return textMessage.getText();
		} else {
			System.out.println("Not a text message.");
		}
		*/
		return null;
	}

	public static void tearDown() {
		try {
			destination = null;
			session.close();
			connection.close();
		} catch (JMSException e) {
			System.out.println("Exception occurred while stopping consumer. " + e.getMessage());
		}
	}

	private static class MyConsumerListener implements MessageListener,ExceptionListener {
		@Override
		public void onMessage(Message message) {
			try {
				if (message instanceof TextMessage) {
					TextMessage textMessage = (TextMessage) message;
					System.out.println("Message received : " + textMessage.getText());
				} else {
					System.out.println("Not a text message.");
				}
			} catch (JMSException e) {
				System.out.println("Exception while reading message.");
			}
		}
		
		@Override
		public void onException(JMSException e) {
			System.out.println("Exception");
		}
	}

	public static void main(String[] args) {
		try {
			setUp();
		} catch (JMSException e) {
			e.printStackTrace();
		}

		try {
//			while (true) {
				System.out.println("Message received : " + receiveMessage());
//			}
		} catch (JMSException e) {
			e.printStackTrace();
		} finally {
			tearDown();
		}
	}
}