Why new `Subscriber` implementation is a decorator for `AbstractService` and not implement `Service` interface directly? It makes it harder to use with `com.google.common.util.concurrent.ServiceManager`