Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #477

This commit is contained in:
Martyn Taylor 2016-04-20 15:12:19 +01:00
parent de0ac57aa4 b89faae458
commit 725379920e
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/LargeServerMessageImpl.java
View File

@ -276,6 +276,10 @@ public final class LargeServerMessageImpl extends ServerMessageImpl implements L
try { try {
LargeServerMessage newMessage = storageManager.createLargeMessage(newID, this); LargeServerMessage newMessage = storageManager.createLargeMessage(newID, this);
boolean originallyOpen = file != null && file.isOpen();
validateFile();
byte[] bufferBytes = new byte[100 * 1024]; byte[] bufferBytes = new byte[100 * 1024];
@ -283,7 +287,6 @@ public final class LargeServerMessageImpl extends ServerMessageImpl implements L
long oldPosition = file.position(); long oldPosition = file.position();
boolean originallyOpen = file.isOpen();
file.open(); file.open();
file.position(0); file.position(0);
@ -294,7 +297,7 @@ public final class LargeServerMessageImpl extends ServerMessageImpl implements L
int bytesRead = file.read(buffer); int bytesRead = file.read(buffer);
byte[] bufferToWrite; byte[] bufferToWrite;
if (bytesRead == 0) { if (bytesRead <= 0) {
break; break;
} }
else if (bytesRead == bufferBytes.length) { else if (bytesRead == bufferBytes.length) {