Где я должен открывать/закрывать соединения JMS в JSF ManagedBean?

В простом демонстрационном веб-приложении, использующем JSF 2 и Ajax, в ManagedBean есть метод, который получает сообщения из очереди JMS:

@ManagedBean
public class Bean {

    @Resource(mappedName = "jms/HabariConnectionFactory")
    private ConnectionFactory connectionFactory;
    @Resource(mappedName = "jms/TOOL.DEFAULT")
    private Queue queue;

    public String getMessage() {
        String result = "no message";
        try {
            Connection connection = connectionFactory.createConnection();
            connection.start();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            MessageConsumer consumer = session.createConsumer(queue);
            Message message = consumer.receiveNoWait();
            if (message != null) {
                result = ((TextMessage) message).getText();
            }
            connection.close();
        } catch (JMSException ex) {
            Logger.getLogger(Bean.class.getName()).log(Level.SEVERE, null, ex);
        }
         return result;
    }
}

Соединение JMS открывается/закрывается каждый раз, когда вызывается метод getMessage(). Какие варианты я должен открыть и закрыть соединение JMS только один раз в жизненном цикле bean-компонента, чтобы избежать частых операций подключения/отключения?


java jms jsf jsf-2 managed-bean
person mjn    schedule 03.05.2011    source источник

Ответы (2)


arrow_upward
2
arrow_downward

Во-первых, переместите Connection в переменную экземпляра, чтобы к ней можно было получить доступ из ваших методов open, close и getMessage.

Затем создайте метод openConnection с аннотацией PostConstruct.

@PostConstruct
public void openConnection() {
    connection = connectionFactory.createConnection();
}

Наконец, создайте метод closeConnection с аннотацией PreDestroy.

@PreDestroy
public void closeConnection() {
    connection.close();
}
person Michael Edgar    schedule 10.06.2011

arrow_upward
0
arrow_downward

Как насчет слушателя контекста сервлета?

Просто определите в web.xml

<listener>
  <listener-class>contextListenerClass</listener-class>
</listener>

А затем реализовать servletContextListener

public final class contextListenerClassimplements ServletContextListener {
...
}

Другим решением может быть использование SessionListener...

person Ben    schedule 04.05.2011