log.info("Aggregate {} removeed subscriber {}", aggregate, actorRef);
}
}
} else if (o instanceof Subscription) {
Subscription subscription = (Subscription) o;
<BUG>tryToFillSubscription(sender(), subscription);
} else if (o instanceof RetrieveAggregateEventsAsync) {</BUG>
readAggregateEvents((RetrieveAggregateEventsAsync) o);
} else if (o instanceof String ||
o instanceof Subscription ||

log.info("Aggregate {} removeed subscriber {}", aggregate, actorRef);
}
}
} else if (o instanceof Subscription) {
Subscription subscription = (Subscription) o;
tryToFillSubscription(sender(), subscription);
} else if (o instanceof Messages.AsyncSubscription) {
Messages.AsyncSubscription subscription = (Messages.AsyncSubscription) o;
tryToFillSubscription(sender(), subscription);
} else if (o instanceof RetrieveAggregateEventsAsync) {
readAggregateEvents((RetrieveAggregateEventsAsync) o);
} else if (o instanceof String ||
o instanceof Subscription ||
