Removed dependency on org.apache.commons.io.* from run-time code.

Author: Steve Powell

src/com/rabbitmq/client/impl/TruncatedInputStream.java

@@ -17,16 +17,15 @@
 
 package com.rabbitmq.client.impl;
 
+import java.io.FilterInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 
-import org.apache.commons.io.input.ProxyInputStream;
-
 /**
  * Utility stream: proxies another stream, making it appear to be no
  * longer than a preset limit.
  */
-public class TruncatedInputStream extends ProxyInputStream {
+public class TruncatedInputStream extends FilterInputStream {
     private final long limit;
 
     private long counter = 0L;
@@ -57,10 +56,6 @@ public TruncatedInputStream(InputStream in, long limit) {
             return -1;
     }
 
-    @Override public int read(byte[] b) throws IOException {
-        return read(b, 0, b.length);
-    }
-
     @Override public int read(byte[] b, int off, int len) throws IOException {
 
         if (limit > counter) {

src/com/rabbitmq/client/impl/ValueWriter.java

@@ -19,14 +19,14 @@
 
 import java.io.DataOutputStream;
 import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
 import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.util.Date;
 import java.util.Map;
 import java.util.List;
 
-import org.apache.commons.io.IOUtils;
-
 import com.rabbitmq.client.LongString;
 
 /**
@@ -61,7 +61,18 @@ public final void writeLongstr(LongString str)
         throws IOException
     {
         writeLong((int)str.length());
-        IOUtils.copy(str.getStream(), out);
+        copy(str.getStream(), out);
+    }
+
+    private static final int COPY_BUFFER_SIZE = 4096;
+
+    private static void copy(InputStream input, OutputStream output) throws IOException {
+        byte[] buffer = new byte[COPY_BUFFER_SIZE];
+        int biteSize = input.read(buffer);
+        while (-1 != biteSize) {
+            output.write(buffer, 0, biteSize);
+            biteSize = input.read(buffer);
+        }
     }
 
     /** Public API - encodes a long string from a String. */