set timeout to 5 seconds

assimbly · Oct 3, 2023 · eb87c41 · eb87c41
1 parent 072f5cc
commit eb87c41
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/dil/src/main/java/org/assimbly/dil/event/collect/MessageCollector.java b/dil/src/main/java/org/assimbly/dil/event/collect/MessageCollector.java
@@ -65,9 +65,9 @@ public void notify(CamelEvent event) throws Exception {
             // stepId = ExpressionBuilder.routeIdExpression().evaluate(exchange, String.class);
 
             //process and store the exchange
-            if(stepId!=null && stepId.startsWith(flowId) && filters==null){
+            if (stepId != null && stepId.startsWith(flowId) && filters == null) {
                 processEvent(exchange, flowId, stepId);
-            }else if(stepId!=null && stepId.startsWith(flowId) && EventUtil.isFiltered(filters, stepId)){
+            } else if (stepId != null && stepId.startsWith(flowId) && EventUtil.isFiltered(filters, stepId)) {
                 processEvent(exchange, flowId, stepId);
             }
 

diff --git a/integration/src/main/java/org/assimbly/integration/impl/CamelIntegration.java b/integration/src/main/java/org/assimbly/integration/impl/CamelIntegration.java
@@ -97,7 +97,7 @@ public class CamelIntegration extends BaseIntegration {
 
 	private CamelContext context;
 	private boolean started;
-	private final static int stopTimeout = 10;
+	private final static int stopTimeout = 5;
 	private ServiceStatus status;
 	private String flowStatus;
 	private final MetricRegistry metricRegistry = new MetricRegistry();

diff --git a/pom.xml b/pom.xml
@@ -28,7 +28,7 @@
 		<hamcrest.version>2.2</hamcrest.version>
 		<spring-boot.version>2.7.16</spring-boot.version>
 		<maven-api.version>3.9.4</maven-api.version>
-		<camel-spring-junit5.version>3.20.6</camel-spring-junit5.version>
+		<camel-spring-junit5.version>3.20.7</camel-spring-junit5.version>
 		<h2database.version>2.2.224</h2database.version>
 		<maven.versions.rules>file:///${project.basedir}/rules.xml</maven.versions.rules>
 	</properties>