private CompositeNode transformNotification(final NetconfMessage cachedNotification) {
final CompositeNode parsedNotification = messageTransformer.toNotification(cachedNotification);
- Preconditions.checkNotNull(parsedNotification, "{}: Unable to parse received notification %s", id, cachedNotification);
+ Preconditions.checkNotNull(parsedNotification, "%s: Unable to parse received notification: %s", id, cachedNotification);
return parsedNotification;
}
}
synchronized void onRemoteSchemaDown() {
+ queue.clear();
passNotifications = false;
}
private static final Function<Module, Uri> MODULE_TO_URI = new Function<Module, Uri>() {
@Override
public Uri apply(final Module input) {
- final QName qName = QName.cachedReference(QName.create(input.getQNameModule(), input.getName()));
- return new Uri(qName.toString());
+ return new Uri(new NetconfOperationServiceFactoryImpl.YangStoreCapability(input, input.getSource()).getCapabilityUri());
}
};