From 54906678d08d2a7ab773eee6ab95cdd77c7da2d6 Mon Sep 17 00:00:00 2001
From: Cedric RICARD <cedric.ricard@calexium.com>
Date: Tue, 12 Feb 2008 08:45:31 +0000
Subject: [PATCH] Configurable timeout for netservice client

---
 calexium_lib/net_services/CXM_generic_client.anubis | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/calexium_lib/net_services/CXM_generic_client.anubis b/calexium_lib/net_services/CXM_generic_client.anubis
index b8b51e8..cb80be1 100644
--- a/calexium_lib/net_services/CXM_generic_client.anubis
+++ b/calexium_lib/net_services/CXM_generic_client.anubis
@@ -66,12 +66,13 @@ define Maybe($T)
   generic_handler
   (
     MessageQueue            queue,
+    Int32                   timeout,
     Message                 msg_to_send,
     (Message) -> Maybe($T)  handler,
     (String) -> One         logger
   )=
   queue.add_Message_to_send(msg_to_send);
-  if queue.get_next_received_Message(10) is
+  if queue.get_next_received_Message(timeout) is
   {
     timeout then logger("["+queue.get_name(unique)+"]: receive timeout");failure,
     closed  then logger("["+queue.get_name(unique)+"]: socket closed");failure,
@@ -95,12 +96,13 @@ define Maybe($T)
 public define (MessageQueue) -> Maybe($T)
   make_generic_handler
   (
+    Int32                   timeout,
     Message                 msg_to_send,
     (Message) -> Maybe($T)  handler,
     (String) -> One         logger
   ) =
   (MessageQueue queue) |->
-  generic_handler(queue, msg_to_send, handler, logger).
+  generic_handler(queue, timeout, msg_to_send, handler, logger).
 
 define Maybe($T)
   generic_request_for_service
--
libgit2 0.21.4