sluit brmo framework na laden van bestand

BrmoFramework is onduidelijk over wat er gebeurd, er wordt wel een database verbinding geopend, maar niet gesloten in het proces van het laden van een bestand. Hierdoor kan er uitputting van het aantal database verbindingen optreden.
B3Partners · Jun 25, 2015 · 45c178e · 45c178e
1 parent d798a2d
commit 45c178e
Show file tree

Hide file tree

Showing 3 changed files with 25 additions and 3 deletions.
diff --git a/brmo-loader/src/main/java/nl/b3p/brmo/loader/BrmoFramework.java b/brmo-loader/src/main/java/nl/b3p/brmo/loader/BrmoFramework.java
@@ -149,6 +149,13 @@ public List<Bericht> listBerichten() throws BrmoException {
         }
     }
 
+    /**
+     * @see #loadFromFile(java.lang.String, java.lang.String,
+     * nl.b3p.brmo.loader.ProgressUpdateListener)
+     * @param type
+     * @param fileName
+     * @throws BrmoException
+     */
     public void loadFromFile(String type, String fileName) throws BrmoException {
         try {
             loadFromFile(type, fileName, null);
@@ -157,6 +164,14 @@ public void loadFromFile(String type, String fileName) throws BrmoException {
         }
     }
 
+    /**
+     * NB na gebruik zelf de database verbinding sluiten / opruimen met {@link #closeBrmoFramework()}
+     *
+     * @param type
+     * @param fileName
+     * @param listener
+     * @throws BrmoException
+     */
     public void loadFromFile(String type, String fileName, final ProgressUpdateListener listener) throws BrmoException {
         try {
             if(fileName.toLowerCase().endsWith(".zip")) {

diff --git a/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/BAGDirectoryScanner.java b/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/BAGDirectoryScanner.java
@@ -100,9 +100,10 @@ public void execute() throws BrmoException {
                         sb.append(msg).append(AutomatischProces.LOG_NEWLINE);
                     } else {
                         // TODO gebruik JPA
+                        BrmoFramework brmo = null;
                         try {
                             // 1: laadt in staging.
-                            BrmoFramework brmo = new BrmoFramework(ConfigUtil.getDataSourceStaging(), null);
+                            brmo = new BrmoFramework(ConfigUtil.getDataSourceStaging(), null);
                             brmo.loadFromFile(BrmoFramework.BR_BAG, f.getAbsolutePath());
                             msg = String.format("Bestand %s is geladen.", f);
                             log.info(msg);
@@ -115,6 +116,9 @@ public void execute() throws BrmoException {
                             log.warn(leegEx.getLocalizedMessage());
                             sb.append(leegEx.getLocalizedMessage()).append(AutomatischProces.LOG_NEWLINE);
                         } finally {
+                            if (brmo != null) {
+                                brmo.closeBrmoFramework();
+                            }
                             if (isArchiving) {
                                 // 2: verplaats naar archief (NB mogelijk platform afhankelijk)
                                 f.renameTo(new File(archiefDirectory, f.getName()));

diff --git a/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/BRKDirectoryScanner.java b/brmo-service/src/main/java/nl/b3p/brmo/service/scanner/BRKDirectoryScanner.java
@@ -98,15 +98,15 @@ public void execute() throws BrmoException {
                         log.info(msg);
                         sb.append(msg).append(AutomatischProces.LOG_NEWLINE);
                     } else {
+                        BrmoFramework brmo = null;
                         try {
                             // 1: laadt in staging
                             // TODO gebruik JPA
-                            BrmoFramework brmo = new BrmoFramework(ConfigUtil.getDataSourceStaging(), null);
+                            brmo = new BrmoFramework(ConfigUtil.getDataSourceStaging(), null);
                             brmo.loadFromFile(BrmoFramework.BR_BRK, f.getAbsolutePath());
                             msg = String.format("Bestand %s is geladen.", f);
                             log.info(msg);
                             sb.append(msg).append(AutomatischProces.LOG_NEWLINE);
-
                         } catch (BrmoDuplicaatLaadprocesException duplicaat) {
                             log.info(duplicaat.getLocalizedMessage());
                             sb.append(duplicaat.getLocalizedMessage()).append(AutomatischProces.LOG_NEWLINE);
@@ -115,6 +115,9 @@ public void execute() throws BrmoException {
                             log.warn(leegEx.getLocalizedMessage());
                             sb.append(leegEx.getLocalizedMessage()).append(AutomatischProces.LOG_NEWLINE);
                         } finally {
+                            if (brmo != null) {
+                                brmo.closeBrmoFramework();
+                            }
                             if (isArchiving) {
                                 // 2: verplaats naar archief (NB mogelijk platform afhankelijk)
                                 f.renameTo(new File(archiefDirectory, f.getName()));