- if(message instanceof DataChanged){
- DataChanged reply = (DataChanged) message;
- AsyncDataChangeEvent<InstanceIdentifier, NormalizedNode<?, ?>>
+ if(message.getClass().equals(DataChanged.SERIALIZABLE_CLASS)){
+ DataChanged reply = DataChanged.fromSerialize(schemaContext,message, pathId);
+ AsyncDataChangeEvent<YangInstanceIdentifier, NormalizedNode<?, ?>>