From 1512e12c2cbe3da193133546eb99e507dab5228d Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 10 May 2012 11:45:33 -0400 Subject: [PATCH] Slightly more information at AMQP connection open time --- amqp_relay.ml | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/amqp_relay.ml b/amqp_relay.ml index db3c536..bbd2560 100644 --- a/amqp_relay.ml +++ b/amqp_relay.ml @@ -177,7 +177,12 @@ let issue_banner cin cout = lwt () = Lwt_io.read_into_exactly cin handshake 0 8 in if String.sub handshake 0 4 <> "AMQP" then (lwt () = Lwt_io.write cout "AMQP\000\000\009\001" in return false) - else return true + else (ignore (Log.info "AMQP handshake bytes" + [Sexp.Str (string_of_int (int_of_char (String.get handshake 4))); + Sexp.Str (string_of_int (int_of_char (String.get handshake 5))); + Sexp.Str (string_of_int (int_of_char (String.get handshake 6))); + Sexp.Str (string_of_int (int_of_char (String.get handshake 7)))]); + return true) with End_of_file -> return false let reference_to_logs = "See server logs for details" @@ -260,6 +265,7 @@ let expand_mrdq conn queue = | other -> Node.name_of_string other let handle_method conn channel m = + (* ignore (Log.info "method" [sexp_of_method m]); *) if channel > 1 then die channel_error "Unsupported channel number" else (); match m with | Connection_close (code, text, _, _) ->