org.springframework.jms.IllegalStateException: сеанс закрыт - PullRequest
Новая
       11

org.springframework.jms.IllegalStateException: сеанс закрыт

1 голос
/ 22 апреля 2019

Я использую Apache Camel и ActiveMQ в своем весеннем загрузочном приложении. Иногда он начинает выдавать ошибку, что сессия закрыта. Я должен перезапустить приложение, чтобы избавиться от этой ошибки.

Я просмотрел несколько статей, в которых предполагается, что приложение исчерпывает максимальный лимит сеанса (по умолчанию 500). В следующий раз, когда произойдет эта ошибка, я загляну в панель activemq, чтобы увидеть активные сеансы, соответствующие соединению.

Вот мой файл конфигурации: 

<camelContext id="camelContext" xmlns="http://camel.apache.org/schema/spring">
        <contextScan/>
    </camelContext>

    <bean class="xy.acb.task.TaskServiceBean">
        <property name="camelContext" ref="camelContext"/>
    </bean>

    <bean id="activemq" class="org.apache.activemq.camel.component.ActiveMQComponent" destroy-method="shutdown">
        <property name="autoStartup" value="true"/>
        <property name="connectionFactory">
            <bean class="org.apache.activemq.pool.PooledConnectionFactoryBean">
                <property name="connectionFactory">
                    <bean class="org.apache.activemq.spring.ActiveMQConnectionFactory">
                        <property name="brokerURL"
                                  value="${activemq.brokerURL:tcp://activemq:61616?daemon=true}"/>
                    </bean>
                </property>
            </bean>
        </property>
            <property name="acknowledgementModeName" value="CLIENT_ACKNOWLEDGE"/>
        <property name="deliveryMode" value="1"/>
        <property name="timeToLive" value="1260000"/>
    </bean>

Ниже приведена трассировка ошибки: 

The Session is closed; nested exception is javax.jms.IllegalStateException: The Session is closed
        ; nested exception is javax.jms.IllegalStateException: The Session is closed
        at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:279)
        at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:169)
        at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:496)
        at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:228)
        at org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:431)
        at org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:385)
        at org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:153)
        at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:120)
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:416)
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:118)
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
        at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:51)
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)
        at org.apache.camel.processor.UnitOfWorkProducer.process(UnitOfWorkProducer.java:74)
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:375)
        at org.apache.camel.impl.ProducerCache$2.doInProducer(ProducerCache.java:343)
        at org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:233)
        at org.apache.camel.impl.ProducerCache.sendExchange(ProducerCache.java:343)
        at org.apache.camel.impl.ProducerCache.send(ProducerCache.java:168)
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:119)
        at org.apache.camel.impl.DefaultProducerTemplate.send(DefaultProducerTemplate.java:105)

1 Ответ

0 голосов
/ 23 апреля 2019

Начиная с Activemq 5.7, MaximumActive = 500 (по умолчанию) заменяется свойством MaximumActiveSessionPerConnection.Соединения по умолчанию - 8. Таким образом, разрешено 500 * 8 = 4000 сеансов.Проверьте, какую версию Activemq вы используете, а затем установите нужные свойства, необходимые для его работы.

...