TomEE Embedded ActiveMQ с использованием JMSContext: ManagedConnections недоступны в течение настроенного времени блокировки ( 5000 [мс])
Мое приложение использует 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.
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) {}
}
}
}
}