protected void handleReceive(Object message) throws Exception {
if (message instanceof CloseDataTreeChangeListenerRegistration) {
registration.close();
- if(isValidSender(getSender())) {
+ if (isValidSender(getSender())) {
getSender().tell(CloseDataTreeChangeListenerRegistrationReply.getInstance(), getSelf());
}
return Props.create(new DataTreeChangeListenerRegistrationCreator(registration));
}
- private static final class DataTreeChangeListenerRegistrationCreator implements Creator<DataTreeChangeListenerRegistrationActor> {
+ private static final class DataTreeChangeListenerRegistrationCreator
+ implements Creator<DataTreeChangeListenerRegistrationActor> {
private static final long serialVersionUID = 1L;
final ListenerRegistration<DOMDataTreeChangeListener> registration;