commit | bf8941d87a46f814541460a093f39da9e2de4866 | [log] [tgz] |
---|---|---|
author | Karl Wright <kwright@apache.org> | Mon Jun 17 14:00:13 2013 +0000 |
committer | Karl Wright <kwright@apache.org> | Mon Jun 17 14:00:13 2013 +0000 |
tree | 022304edec03298514e156c170331a0e17477fbf | |
parent | b466e34b3514b05537153adb03a49d119e4ebb19 [diff] |
Override ALL OutputStream methods. git-svn-id: https://svn.apache.org/repos/asf/manifoldcf/branches/CONNECTORS-714@1493761 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java b/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java index dd28e65..7da2306 100644 --- a/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java +++ b/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java
@@ -33,7 +33,17 @@ public XThreadOutputStream(XThreadInputStream inputStream) { this.inputStream = inputStream; } - + + @Override + public void write(byte[] buffer) + throws IOException { + try { + inputStream.stuffQueue(buffer,0,buffer.length); + } catch (InterruptedException e) { + throw new InterruptedIOException(e.getMessage()); + } + } + @Override public void write(int c) throws IOException {