}
@Override
- public void handleReceive(Object message) throws Exception {
+ public void handleReceive(Object message) {
if (message instanceof CloseDataChangeListenerRegistration) {
closeListenerRegistration();
+ } else {
+ unknownMessage(message);
}
}
private void closeListenerRegistration() {
registration.close();
- getSender().tell(CloseDataChangeListenerRegistrationReply.INSTANCE, getSelf());
+
+ if(isValidSender(getSender())) {
+ getSender().tell(CloseDataChangeListenerRegistrationReply.INSTANCE, getSelf());
+ }
+
getSelf().tell(PoisonPill.getInstance(), getSelf());
}