Extend ack deadline for candidate base graph route (#652)

entur · Feb 4, 2025 · ec85243 · ec85243
1 parent c8359f5
commit ec85243
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/no/rutebanken/marduk/routes/otp/otp2/Otp2BaseGraphRouteBuilder.java b/src/main/java/no/rutebanken/marduk/routes/otp/otp2/Otp2BaseGraphRouteBuilder.java
@@ -61,7 +61,7 @@ public void configure() throws Exception {
                 .to("direct:buildOtp2BaseGraph")
                 .routeId("pubsub-otp2-base-graph-build");
 
-        singletonFrom("google-pubsub:{{marduk.pubsub.project.id}}:Otp2BaseGraphCandidateBuildQueue").autoStartup("{{otp2.graph.build.autoStartup:true}}")
+        singletonFrom("google-pubsub:{{marduk.pubsub.project.id}}:Otp2BaseGraphCandidateBuildQueue?maxAckExtensionPeriod=14400").autoStartup("{{otp2.graph.build.autoStartup:true}}")
                 .process(this::removeSynchronizationForAggregatedExchange)
                 .aggregate(new GroupedMessageAggregationStrategy()).constant(true).completionSize(100).aggregateController(idleRouteAggregationMonitor.getAggregateControllerForRoute("otp2-base-graph-build"))
                 .process(this::addSynchronizationForAggregatedExchange)