You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@manifoldcf.apache.org by kw...@apache.org on 2013/06/17 16:00:13 UTC
svn commit: r1493761 -
/manifoldcf/branches/CONNECTORS-714/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java
Author: kwright
Date: Mon Jun 17 14:00:13 2013
New Revision: 1493761
URL: http://svn.apache.org/r1493761
Log:
Override ALL OutputStream methods.
Modified:
manifoldcf/branches/CONNECTORS-714/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java
Modified: manifoldcf/branches/CONNECTORS-714/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-714/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java?rev=1493761&r1=1493760&r2=1493761&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-714/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java (original)
+++ manifoldcf/branches/CONNECTORS-714/framework/core/src/main/java/org/apache/manifoldcf/core/common/XThreadOutputStream.java Mon Jun 17 14:00:13 2013
@@ -33,7 +33,17 @@ public class XThreadOutputStream extends
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 {