From af90bc5f435c8e8acaa524602067dbbc5606a662 Mon Sep 17 00:00:00 2001
From: Martyn Taylor <mtaylor@redhat.com>
Date: Wed, 1 Aug 2018 17:54:35 +0100
Subject: [PATCH] Make OpenFile Thread Safe

---
 .../file/JDBCSequentialFileFactoryDriver.java      | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java
index 14ad25e825..e736dcadd0 100644
--- a/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java
+++ b/artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java
@@ -108,12 +108,14 @@ public class JDBCSequentialFileFactoryDriver extends AbstractJDBCDriver {
     * @throws SQLException
     */
    public void openFile(JDBCSequentialFile file) throws SQLException {
-      final long fileId = fileExists(file);
-      if (fileId < 0) {
-         createFile(file);
-      } else {
-         file.setId(fileId);
-         loadFile(file);
+      synchronized (connection) {
+         final long fileId = fileExists(file);
+         if (fileId < 0) {
+            createFile(file);
+         } else {
+            file.setId(fileId);
+            loadFile(file);
+         }
       }
    }