У меня есть NIFI-процессор, который подписывается на несколько тегов на сервере OPC UA.
Я изо всех сил пытаюсь найти способ прекратить подписку. Мой план состоял в том, чтобы просто запустить его, пока я не решу остановить процессор.
Я пытался определить функции для @OnStopped, @OnUnscheduled и @OnDisabled, но они никогда не вызываются, когда я останавливаю или отключаю процессор.
Я нахожусь на NIFI 1.7, поэтому я могу завершить процессорный поток, но мои функции @OnStopped, @OnUnscheduled и @OnDisabled по-прежнему не вызываются.
Означает ли завершение потока, что поток не вернется из onTrigger способом, позволяющим вызывать вышеупомянутые методы жизненного цикла?
РЕДАКТИРОВАТЬ: В соответствии с просьбой, мой метод с аннотацией:
@OnStopped
private void OnStopped() {
getLogger().info("Subscriptions cleared - stopped");
miloOpcUAService.clearSubscriptions();
}