diff options
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/store/DerbyMessageStore.java | 9 |
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()); |