TomEE Embedded ActiveMQ с использованием JMSContext: ManagedConnections недоступны в течение настроенного времени блокировки ( 5000 [мс])

Question

Мое приложение использует ActiveMQ, встроенный в TomEE Plus-8.0.0-M1.

Поведение исчерпания подключений в пуле одинаково, независимо от использования явно определенного javax.jms.ConnectionFactory с использованием resources.xml или разрешения TomEE создавать его на лету.

Различные настройки для времени ожидания соединения, кажется, не имеют эффекта:

connectionMaxIdleTime = 3 seconds
connectionMaxIdleTime = 15 minutes

Если ExampleSessionBean.sendMessage() вызывается 11 раз подряд, предупреждения об оставленном соединении регистрируются в сообщениях 1-10. В сообщении № 11 выдается исключение JMSRuntimeException: нет доступных управляемых соединений.

Затем, если я подожду несколько минут, продюсер JMSContext сможет отправить снова.

Моей первой мыслью было, что базовое соединение в JMSContext необходимо закрыть

jmsContext.close();

но из интерфейса JMSContext

"Этот метод нельзя использовать, если JMSContext управляется контейнером (внедряется)".

Какие программные или конфигурационные изменения необходимы здесь?

Спасибо, Тед С

resources.xml

<?xml version="1.0" encoding="UTF-8"?>
<resources>
    <Resource id="jmsConnectionFactory" type="javax.jms.ConnectionFactory">
        connectionMaxIdleTime = 3 seconds
        connectionMaxWaitTime = 5 seconds
        poolMaxSize = 10
        poolMinSize = 0
        resourceAdapter = Default JMS Resource Adapter
        transactionSupport = xa
    </Resource>
</resources>

ExampleSessionBean.java

@Named
@LocalBean
@Stateless
public class ExampleSessionBean
{

    @Resource(name = "jms/localNotificationQueue")
    private Queue _localNotificationQueue;

    @Inject
    @JMSConnectionFactory("jmsConnectionFactory")
    private JMSContext _jmsContext;

    public void sendMessage(String message) 
    {
        try
        {      
            TextMessage textMessage = 
                _jmsContext.createTextMessage(message);
            _jmsContext.createProducer().
                setDeliveryMode(DeliveryMode.PERSISTENT).
                send(_localNotificationQueue, textMessage);   
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
    }
}

Предупреждения - Сообщения 1-10: (простите за форматирование. SE форматер не будет форматировать этот текстовый блок по некоторым причинам)

Начать текст предупреждения

ПРЕДУПРЕЖДЕНИЕ. Транзакция завершена, но с соединением все еще связаны дескрипторы: ManagedConnectionInfo:... org.apache.openejb.resource.activemq.jms2.cdi.JMS2CDIExtension $ InternalJMSContext.createProducer (JMS2CDIExtension.java:370), com.myorg.jms. ExampleSessionBean.sendMessage (ExampleSessionBean.java:46),

...

Конец предупреждения

Сообщение № 11 Исключение

javax.jms.JMSRuntimeException: No ManagedConnections available within configured blocking timeout ( 5000 [ms] ) for pool org.apache.geronimo.connector.outbound.SinglePoolConnectionInterceptor@12aff7fa
    at org.apache.openejb.resource.activemq.jms2.JMS2.toRuntimeException(JMS2.java:83)
    at org.apache.openejb.resource.activemq.jms2.JMSContextImpl.connection(JMSContextImpl.java:85)
    at org.apache.openejb.resource.activemq.jms2.JMSContextImpl.session(JMSContextImpl.java:102)
    at org.apache.openejb.resource.activemq.jms2.JMSContextImpl.getInnerProducer(JMSContextImpl.java:124)
    at org.apache.openejb.resource.activemq.jms2.JMSContextImpl.createProducer(JMSContextImpl.java:302)
    at org.apache.openejb.resource.activemq.jms2.cdi.JMS2CDIExtension$InternalJMSContext.createProducer(JMS2CDIExtension.java:370)
    at com.myorg.jms.ExampleSessionBean.sendMessage(ExampleSessionBean.java:46)
...

ОБНОВЛЕНИЕ: Это поведение было продублировано и добавлено в систему отслеживания проблем TomEE.

Answer 1

Я разочаровался в JMSContext и вернулся к ручному управлению соединением. Все функции, как ожидается, даже при загрузке с сотнями сообщений.

ExampleSessionBean.java

@Named
@LocalBean
@Stateless
public class ExampleSessionBean
{
    @Resource(name = "jms/localNotificationQueue")
    private Queue _localNotificationQueue;

    @Resource(mappedName = "jmsConnectionFactory")
    private ConnectionFactory _connectionFactory;    

    public void sendMessage(String message) 
    {
        Connection connection = null;
        Session session = null;
        MessageProducer messageProducer = null;
        try
        {      
            connection = 
                    _connectionFactory.createConnection();
            connection.start();
            session =
                    connection.createSession();
            messageProducer =
                    session.createProducer(null);
            messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);
            TextMessage textMessage = session.createTextMessage(message);
            messageProducer.send(_localNotificationQueue, 
                    textMessage);   
        }
        catch (Exception e)
        {
            // TODO Handle exception
        }
        finally
        {
            if (connection != null)
            {
                try
                {
                    connection.close();
                }
                catch (JMSException e) {}
            }
        }
    }
}