Change RpcImplementation contract to asynchronous

[controller.git] / opendaylight / md-sal / sal-netconf-connector / src / main / java / org / opendaylight / controller / sal / connect / netconf / YangModelInputStreamAdapter.java

diff --git a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/YangModelInputStreamAdapter.java b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/YangModelInputStreamAdapter.java
index bc819b65636abbcdb72371ed9ce8866ce88fb640..23892e18bd4e171d41437c2b40a3ec058f4f317a 100644 (file)
--- a/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/YangModelInputStreamAdapter.java
+++ b/opendaylight/md-sal/sal-netconf-connector/src/main/java/org/opendaylight/controller/sal/connect/netconf/YangModelInputStreamAdapter.java
@@ -7,13 +7,15 @@
  */
 package org.opendaylight.controller.sal.connect.netconf;
 
+import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
-import java.io.StringBufferInputStream;
 
 import org.opendaylight.yangtools.concepts.Delegator;
 import org.opendaylight.yangtools.yang.common.QName;
 
+import com.google.common.base.Charsets;
+
 /**
  *
  *
@@ -24,8 +26,6 @@ public class YangModelInputStreamAdapter extends InputStream implements Delegato
     final QName moduleIdentifier;
     final InputStream delegate;
 
-
-
     private YangModelInputStreamAdapter(String source, QName moduleIdentifier, InputStream delegate) {
         super();
         this.source = source;
@@ -99,7 +99,6 @@ public class YangModelInputStreamAdapter extends InputStream implements Delegato
     }
 
     public static YangModelInputStreamAdapter create(QName name, String module) {
-        InputStream stringInput = new StringBufferInputStream(module);
-        return new YangModelInputStreamAdapter(null, name, stringInput );
+        return new YangModelInputStreamAdapter(null, name, new ByteArrayInputStream(module.getBytes(Charsets.UTF_8)));
     }
 }