+ @Override
+ public Registration notifyWhenBackendInfoIsStale(final Consumer<Long> callback) {
+ staleBackendInfoCallbacks.add(callback);
+ return () -> staleBackendInfoCallbacks.remove(callback);
+ }
+
+ protected void notifyStaleBackendInfoCallbacks(Long cookie) {
+ staleBackendInfoCallbacks.forEach(callback -> callback.accept(cookie));
+ }
+
+ protected ActorContext actorContext() {
+ return actorContext;
+ }
+