diff --git a/Server/src/config/config.xml b/Server/src/config/config.xml index bf866ca9..d5df8cc7 100644 --- a/Server/src/config/config.xml +++ b/Server/src/config/config.xml @@ -81,6 +81,8 @@ pollerConfigBase.defaults="sender.as2_id=$partnership.sender.as2_id$, receiver.as2_id=$partnership.receiver.as2_id$" pollerConfigBase.sendfilename="true" pollerConfigBase.mimetype="application/EDI-X12" + pollerConfigBase.process_files_in_paralllel="false" + pollerConfigBase.max_parallel_files="20" partnerships.polling.interval="120" messages.polling.interval="120" /> @@ -236,7 +238,9 @@ interval="$properties.pollerConfigBase.interval$" defaults="$properties.pollerConfigBase.defaults$" sendfilename="$properties.pollerConfigBase.sendfilename$" - mimetype="$properties.pollerConfigBase.mimetype$"/> + mimetype="$properties.pollerConfigBase.mimetype$" + process_files_in_paralllel="$properties.pollerConfigBase.process_files_in_paralllel$" + max_parallel_files="$properties.pollerConfigBase.max_parallel_files$"/> diff --git a/Server/src/main/java/org/openas2/processor/receiver/DirectoryPollingModule.java b/Server/src/main/java/org/openas2/processor/receiver/DirectoryPollingModule.java index 7a51693a..e7e6bbb3 100644 --- a/Server/src/main/java/org/openas2/processor/receiver/DirectoryPollingModule.java +++ b/Server/src/main/java/org/openas2/processor/receiver/DirectoryPollingModule.java @@ -57,7 +57,7 @@ public void init(Session session, Map options) throws OpenAS2Exc IOUtil.getDirectoryFile(sentDir); } processFilesAsThreads = getParameter(PARAM_PROCESS_IN_PARALLEL, "false").equalsIgnoreCase("true"); - maxProcessingThreads = getParameterInt(PARAM_PROCESS_IN_PARALLEL, false, maxProcessingThreads); + maxProcessingThreads = getParameterInt(PARAM_MAX_PARALLEL_FILES, false, maxProcessingThreads); if (processFilesAsThreads) { // Create the thread pool executorService = Executors.newFixedThreadPool(maxProcessingThreads); diff --git a/pom.xml b/pom.xml index fad1e89c..937eac2a 100644 --- a/pom.xml +++ b/pom.xml @@ -128,14 +128,14 @@ org.mockito mockito-core - 5.5.0 + 4.11.0 test org.mockito mockito-junit-jupiter - 5.5.0 + 4.11.0 test