Source

core hello world / broker_server.ml

Diff from to

File broker_server.ml

 (* First, we build the implementations *)
 
 let publish_impl (dir,_) msg =
+  Log.Global.sexp ~level:`Debug msg
+    (Message.sexp_of_t);
   return (Directory.publish dir msg)
 
 let subscribe_impl (dir,_) topic ~aborted =