Merge pull request #713 from luraproject/fix_async_timeouts

Async Agents: set the proper timeouts
luraproject · Mar 7, 2024 · 6e9eacf · 6e9eacf
2 parents 54ecfd5 + ebe2413
commit 6e9eacf
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/async/asyncagent.go b/async/asyncagent.go
@@ -1,7 +1,6 @@
 // SPDX-License-Identifier: Apache-2.0
 
 /*
-
  */
 package async
 
@@ -66,8 +65,13 @@ func (a AgentStarter) Start(
 
 		logger.Debug(fmt.Sprintf("[SERVICE: AsyncAgent][%s] Starting the async agent", agent.Name))
 
+		for i := range agent.Backend {
+			agent.Backend[i].Timeout = agent.Consumer.Timeout
+		}
+
 		endpoint := &config.EndpointConfig{
 			Endpoint:    agent.Name,
+			Timeout:     agent.Consumer.Timeout,
 			Backend:     agent.Backend,
 			ExtraConfig: agent.ExtraConfig,
 		}