- @Override public void handleReceive(Object message) throws Exception {
- if(message instanceof DataChanged){
- DataChanged reply = (DataChanged) message;
- AsyncDataChangeEvent<InstanceIdentifier, NormalizedNode<?, ?>>
- change = reply.getChange();
- this.listener.onDataChanged(change);
+ @Override
+ public void handleReceive(Object message) {
+ if (message instanceof DataChanged) {
+ dataChanged(message);
+ } else if (message instanceof EnableNotification) {
+ enableNotification((EnableNotification) message);
+ } else {
+ unknownMessage(message);
+ }
+ }
+
+ private void enableNotification(EnableNotification message) {
+ notificationsEnabled = message.isEnabled();
+ LOG.debug("{} notifications for listener {}", notificationsEnabled ? "Enabled" : "Disabled",
+ listener);
+ }