protected void handleReceive(Object message) throws Exception {
if (message instanceof CloseDataTreeChangeListenerRegistration) {
registration.close();
- getSender().tell(CloseDataTreeChangeListenerRegistrationReply.getInstance(), getSelf());
+ if(isValidSender(getSender())) {
+ getSender().tell(CloseDataTreeChangeListenerRegistrationReply.getInstance(), getSelf());
+ }
+
getSelf().tell(PoisonPill.getInstance(), getSelf());
} else {
unknownMessage(message);