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 #2235 Make JDBC OpenFile Thread Safe

This commit is contained in:
andytaylor 2018-08-10 13:35:23 +01:00
parent f346347b01 af90bc5f43
commit 3ac7b9aef6
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
artemis-jdbc-store/src/main/java/org/apache/activemq/artemis/jdbc/store/file/JDBCSequentialFileFactoryDriver.java
View File

@ -108,12 +108,14 @@ public class JDBCSequentialFileFactoryDriver extends AbstractJDBCDriver {
* @throws SQLException * @throws SQLException
*/ */
public void openFile(JDBCSequentialFile file) throws SQLException { public void openFile(JDBCSequentialFile file) throws SQLException {
final long fileId = fileExists(file); synchronized (connection) {
if (fileId < 0) { final long fileId = fileExists(file);
createFile(file); if (fileId < 0) {
} else { createFile(file);
file.setId(fileId); } else {
loadFile(file); file.setId(fileId);
loadFile(file);
}
} }
} }