var SchemaSourceProvider<String> delegate;
if (NetconfRemoteSchemaSourceProvider.isSupportedFor(initialCapabilities)) {
delegate = new NetconfRemoteSchemaSourceProvider(this);
- } else {
+ } else if(client.capabilities.contains(NetconfRemoteSchemaSourceProvider.IETF_NETCONF_MONITORING.namespace.toString)) {
+ delegate = new NetconfRemoteSchemaSourceProvider(this);
+ } else {
logger.info("Netconf server {} does not support IETF Netconf Monitoring", socketAddress);
delegate = SchemaSourceProviders.<String>noopProvider();
}
new(NetconfDevice device, SchemaSourceProvider<InputStream> sourceProvider) {
_device = device
_sourceProvider = sourceProvider
+ _currentContext = Optional.absent();
}
def createContextFromCapabilities(Iterable<QName> capabilities) {