JMS MessageListener запущен из ServletContextListener Останавливается через некоторое время

Question

Я создаю веб-приложение RichFaces, которое работает на ОС JBOSS 5.1.0ga AS / Sun.Приложение также обрабатывает запросы JMS (чтение запроса из очереди Weblogic, запущенной на другом сервере, и запись ответа обратно в другую очередь Weblogic, запущенную на этом сервере).Я использовал асинхронную обработку сообщений, расширив класс MessageListener и запустив прослушивание в ServletContextListener.Все работает нормально, но через некоторое время (по крайней мере, через 5-6 часов) Слушатель перестает слушать очередь, и, если я перезагружаю сервер, слушатель также читает старые сообщения.Я не могу понять, почему это останавливается в середине.Есть ли другой эффективный способ запустить прослушиватель в веб-приложении?

ServletContextListener

public class WebApplicationListener implements ServletContextListener {
public void contextInitialized(ServletContextEvent contextEvent) {
    System.out.println("Starting the JMS Listener");
    new JMSConnector().startListening();
}

public void contextDestroyed(ServletContextEvent contextEvent) {
}

}

JMS-коннектор

public class JMSConnector{
static Properties properties = new Properties();

static Context context;
static QueueConnectionFactory connFactory;
static {
    Properties props = new Properties();
    InputStream inputStream = new JMSConnector().getClass()
            .getClassLoader()
            .getResourceAsStream("jmsconnection.properties");
    // ClassLoader.getSystemResource("/HibernateConfigFile.properties").openStream()
    try {
        properties.load(inputStream);
    } catch (IOException e1) {
        // TODO Auto-generated catch block
        e1.printStackTrace();
    }
    props.setProperty(Context.INITIAL_CONTEXT_FACTORY,
            properties.getProperty("context_factory_class"));
    // props.setProperty("java.naming.factory.url.pkgs",
    // properties.getProperty("naming_url_pkgs"));
    props.setProperty(Context.PROVIDER_URL,
            properties.getProperty("provider_url"));
    try {
        context = new InitialContext(props);
        connFactory = (QueueConnectionFactory) context.lookup(properties
                .getProperty("connection_factory_name"));
    } catch (NamingException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}


public void sendMessage(String responseMessage) throws Exception {

    QueueConnection conn = connFactory.createQueueConnection();
    // This session is not transacted, and it uses automatic message
    // acknowledgement
    QueueSession session = conn.createQueueSession(false,
            Session.AUTO_ACKNOWLEDGE);
    Queue q = (Queue) context.lookup(properties
            .getProperty("responsequeue"));
    // Sender
    QueueSender sender = session.createSender(q);
    // Text message
    TextMessage msg = session.createTextMessage();
    msg.setText(responseMessage);
    System.out.println("Sending the message: " + msg.getText());
    sender.send(msg);
    session.close();
    conn.close();
}
public void startListening() {
    try {

        System.out.println("In Start Listening");

        QueueConnection conn = connFactory.createQueueConnection();
        // This session is not transacted, and it uses automatic message
        // acknowledgement
        QueueSession session = conn.createQueueSession(false,
                Session.AUTO_ACKNOWLEDGE);
        Queue q = (Queue) context.lookup(properties
                .getProperty("requestqueue"));

        QueueReceiver receiver = session.createReceiver(q);
        RequestListener requestListener = new RequestListener();
        receiver.setMessageListener(requestListener);
        conn.start();

    } catch (Exception e) {
        e.printStackTrace();
    }
}

MessageListener

public class RequestListener implements MessageListener {

/**
 * Casts the message to a TextMessage and displays its text.
 * 
 * @param message
 *            the incoming message
 */
public void onMessage(Message message) {
    System.out.println("Message Received");
    TextMessage msg = null;

    try {
        if (message instanceof TextMessage) {
            msg = (TextMessage) message;
            String requestXml = msg.getText();
            //Calling Processing Methods
            new JMSConnector().sendMessage(responseXml);
        } else {
            System.out.println("Message of wrong type: "
                    + message.getClass().getName());
        }
    } catch (JMSException e) {
        System.out.println("JMSException in onMessage(): " + e.toString());
    } catch (Throwable t) {
        System.out.println("Exception in onMessage():" + t.getMessage());
    }
}

}