Сценарий потери сообщения Spring интеграции

Сводка - потеря сообщения при систематическом завершении работы приложения.

У меня есть приложение, написанное с использованием Spring интеграции, и я использую запросы от внешних систем с помощью jms: message-driven-channel-adapter. Это конфигурация адаптера канала -

<jms:message-driven-channel-adapter id = "InboundAdapter" destination = "InQueue"
                                        connection-factory = "connectionFactory"
                                        channel = "responseChannel"
                                        error-channel = "errorChannel"
                                        acknowledge = "transacted"
                                        receive-timeout = "50000"
                                        auto-startup = "true"/>

мой канал ответа выглядит так -

 <int:chain id = "processorChain" input-channel = "responseChannel">
        <int:service-activator method = "doProcess" ref = "inputProcessor" />

        <int:router id = "inputRouter" method = "route">
            <int:mapping value = "REQUIRED" channel = "builderChannel"/>
            <int:mapping value = "NOT_REQUIRED" channel = "TerminateChannel"/>
            <bean id = "Router" class = "xxx.xxx.Router">
            </bean>
        </int:router>
    </int:chain>

Теперь, когда я выполняю kill -9 pid, я вижу, что сообщение откатывается в очередь, и все в порядке. Но когда я выполняю kill pid, сообщение где-то теряется. Я включил журналы jms и вижу, что прослушиватель JMS ожидает завершения передачи сообщения перед закрытием потребителя JMS, но все же я не возвращаю сообщение в мою очередь. Это фрагмент журнала, который я вижу в своих журналах.

trace: 15.11.18 15: 42: 46.619 [Thread-10] DEBUG org.springframework.jms.listener.DefaultMessageListenerContainer - Ожидание завершения работы вызывающих прослушивателей сообщений трассировка: 15.11.18 15: 42: 46.619 [Thread-10] DEBUG org.springframework.jms.listener.DefaultMessageListenerContainer - все еще ожидает завершения работы 1 вызывающих обработчиков сообщений (итерация 0)

После регистрации он вызывает активаторы службы, указанные в канале ответа.

Может ли кто-нибудь пролить свет на приведенное выше поведение, я ожидал, что, когда мы выдадим команду kill, все сообщения, которые находятся в пути, должны быть возвращены в очередь, вместо этого он пытается вызвать активаторы, определенные с помощью in channel и после вызова последнего компонента, который является маршрутизатором, он просто завершает работу.

Любая помощь по этой теме будет действительно полезна !!

После некоторой отладки и ударов головой о системе я нашел точный сценарий, в котором это происходит. Позвольте мне объяснить это, чтобы увидеть, имеет ли это смысл. Когда запускается систематическое завершение работы, JMS ожидает завершения передачи сообщений перед остановкой приложения, до этого момента все в порядке. В настоящее время эта цепочка выполняется -

<int:chain input-channel = "inputchain">
    <int:transformer id = "xxx" method = "transform">
        <bean class = "xxx" />
    </int:transformer>

    <int:service-activator  id = "xxx" method = "doProcess">
        <bean class = "xx">
            <constructor-arg ref = "xxx"/>
        </bean>
    </int:service-activator>

    <int:service-activator id = "xxx" ref = "rulesProcessor" method = "doProcess"/>
    <int:service-activator id = "xxx" ref = "xxx" method = "doProcess"/>

    <!-- Existing Flow Continues -->
    <int:router id = "xxxRequiredRouter" method = "xxxRequired">
        <int:mapping value = "Required" channel = "firstChannel"/>
        <int:mapping value = "NotRequired" channel = "secondChannel"/>
        <bean id = "xxxRouter" class = "xxx.Router" />
        </bean>
    </int:router>

</int:chain>

<int:chain input-channel = "secondChannel">

   some logic

</int:chain>

Таким образом, поток завершает эту цепочку и изящно выходит. Он не называет мою следующую цепочку "secondChannel". Граница моей транзакции не заканчивается в этой цепочке inputchain, она заканчивается в конце secondChannel. Итак, я не отправил эту транзакцию в базу данных, поскольку граница транзакции находится в конце следующей цепочки, поэтому это недоступно в БД, и приложение думает, что выполнение цепочки завершено, поэтому оно завершено, поэтому оно не откатывается до очереди также. В конце концов, у меня нет этого сообщения в моей базе данных и его нет в очереди.

Так ли это, что только та цепочка, которая выполняется при срабатывании выключения, завершится, и она не будет делегировать обработку последующим цепочкам?