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, _, _) ->