diff --git a/node.ml b/node.ml
index 0074192..b9602a5 100644
--- a/node.ml
+++ b/node.ml
@@ -22,10 +22,11 @@ open Status
 
 type handle_message_t = t -> Sexp.t -> unit Lwt.t
 and t = {
-    mutable names: StringSet.t;
-    class_name: string;
-    handle_message: handle_message_t
-  }
+  mutable names: StringSet.t;
+  mutable send_counter: int;
+  class_name: string;
+  handle_message: handle_message_t
+}
 and name = {
     label: string;
     mutable binding: t option
@@ -52,6 +53,7 @@ let local_container_name () = "server"
 
 let make class_name handler = {
   names = StringSet.empty;
+  send_counter = 0;
   class_name = class_name;
   handle_message = handler
 }
@@ -120,12 +122,19 @@ let unbind_all n =
 let send name body =
   match lookup name with
     | Some n ->
-      ignore
+      lwt () =
 	(try_lwt n.handle_message n body
 	 with e ->
 	   Log.warn "Node message handler raised exception"
 	     [Sexp.Str name.label;
-	      Sexp.Str (Printexc.to_string e)]);
+	      Sexp.Str (Printexc.to_string e)])
+      in
+      n.send_counter <- n.send_counter + 1;
+      lwt () =
+	if n.send_counter >= 1000
+	then (n.send_counter <- 0; Lwt_unix.yield ())
+	else return ()
+      in
       return true
     | None ->
       return false