ARTEMIS-1514 Fix File open on Large Message

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

@@ -205,6 +205,7 @@ public final class LargeServerMessageImpl extends CoreMessage implements LargeSe
    @Override
    public ActiveMQBuffer getReadOnlyBodyBuffer() {
       try {
+         validateFile();
          file.open();
          int fileSize = (int) file.size();
          ByteBuffer buffer = this.storageManager.largeMessagesFactory.newBuffer(fileSize);

tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/openwire/OpenWireLargeMessageTest.java

@@ -64,6 +64,11 @@ public class OpenWireLargeMessageTest extends BasicOpenWireTest {
 
    @Test
    public void testSendReceiveLargeMessage() throws Exception {
+      // Create 1MB Message
+      int size = 1024 * 1024;
+
+      byte[] bytes = new byte[size];
+
       try (Connection connection = factory.createConnection()) {
          connection.start();
 
@@ -72,14 +77,21 @@ public class OpenWireLargeMessageTest extends BasicOpenWireTest {
          MessageProducer producer = session.createProducer(queue);
          producer.setDeliveryMode(DeliveryMode.PERSISTENT);
 
-         // Create 1MB Message
-         int size = 1024 * 1024;
-         byte[] bytes = new byte[size];
          bytes[0] = 1;
 
          BytesMessage message = session.createBytesMessage();
          message.writeBytes(bytes);
          producer.send(message);
+      }
+
+      server.stop();
+      server.start();
+
+      try (Connection connection = factory.createConnection()) {
+         connection.start();
+         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+         Queue queue = session.createQueue(lmAddress.toString());
+
 
          MessageConsumer consumer = session.createConsumer(queue);
          BytesMessage m = (BytesMessage) consumer.receive();