Current taskmanager (2.x and 3.x) implementation is a self written, in parts non error free (see #4135 ) or need some improvements (see #4136 ) and did not have any kind of unit or integration tests. Maybe ReactiveX/RxJava could be a possible replacement for a future and more advantage usage.