Custom origin having Java ScheduledExecutorService do not stop in background even if Pipeline is stopped
Hi ,
I have developed Custom origin Scheduler , which uses JAVA ScheduledExecutorService to provide different information in different intervals periodically.
It works good but when during execution we are facing 2 problems
1- [Major ] Executor service remains running in background even when i do Force Stop Pipeline
2- When i do stop it remains in stopping mode and i need to go for force stop
I used solutions : 1- Stopping executor service forcefully in @destroy method but during Force stop I don't think destroy method is called as i can not see in logs.
Can some one please help me regarding this?
When we do forcestop which method is ideally called if I am implementing BasePushSource.
Regards, Ankit