QPID-832: fixed DerbyMessageStore to compile on Java 1.5 (hopefully)

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@651276 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 4 deletions

diff --git a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java b/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
index 4664fd5e14..bd980c696c 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java
@@ -638,8 +638,9 @@ public class DerbyMessageStore implements MessageStore
                     blobArgs.setBytes(0, args.getDataAsBytes());
                     stmt.setBlob(4, blobArgs);
                     */
-                    ByteArrayInputStream bis = new ByteArrayInputStream(args.getDataAsBytes());
-                    stmt.setBinaryStream(4, bis);
+                    byte[] bytes = args.getDataAsBytes();
+                    ByteArrayInputStream bis = new ByteArrayInputStream(bytes);
+                    stmt.setBinaryStream(4, bis, bytes.length);
                 }
                 else
                 {
@@ -1043,7 +1044,7 @@ public class DerbyMessageStore implements MessageStore
             stmt.setBlob(3, dataAsBlob);
             */
             ByteArrayInputStream bis = new ByteArrayInputStream(chunkData);
-            stmt.setBinaryStream(3, bis);
+            stmt.setBinaryStream(3, bis, chunkData.length);
             stmt.executeUpdate();
             connWrapper.requiresCommit();
 
@@ -1093,7 +1094,7 @@ public class DerbyMessageStore implements MessageStore
             stmt.setBlob(6, dataAsBlob);
 */
             ByteArrayInputStream bis = new ByteArrayInputStream(underlying);
-            stmt.setBinaryStream(6,bis);
+            stmt.setBinaryStream(6,bis,underlying.length);
 
             stmt.setInt(7, mmd.getContentChunkCount());