Pierre Villard created NIFI-16287:
-------------------------------------

             Summary: Ensure orderly shutdown of active and idle JMS workers
                 Key: NIFI-16287
                 URL: https://issues.apache.org/jira/browse/NIFI-16287
             Project: Apache NiFi
          Issue Type: Improvement
            Reporter: Pierre Villard
            Assignee: Pierre Villard


AbstractJMSProcessor currently tracks only idle workers in its pool, so workers 
executing ConsumeJMS or PublishJMS may retain JMS connections when a processor 
is unscheduled or loses primary-node ownership. Introduce scheduling-cycle 
ownership for all JMS workers, close active and idle workers during early 
lifecycle shutdown, prevent retired workers from being rebuilt or returned to 
the pool, and make worker shutdown idempotent and exception-tolerant. Add 
deterministic tests covering concurrent construction and shutdown, blocked 
receives, delayed acknowledgement and redelivery, primary-node transitions, and 
interrupted publishes.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to