Slightly more information at AMQP connection open time
This commit is contained in:
parent
aa87e25a95
commit
1512e12c2c
|
@ -177,7 +177,12 @@ let issue_banner cin cout =
|
||||||
lwt () = Lwt_io.read_into_exactly cin handshake 0 8 in
|
lwt () = Lwt_io.read_into_exactly cin handshake 0 8 in
|
||||||
if String.sub handshake 0 4 <> "AMQP"
|
if String.sub handshake 0 4 <> "AMQP"
|
||||||
then (lwt () = Lwt_io.write cout "AMQP\000\000\009\001" in return false)
|
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
|
with End_of_file -> return false
|
||||||
|
|
||||||
let reference_to_logs = "See server logs for details"
|
let reference_to_logs = "See server logs for details"
|
||||||
|
@ -260,6 +265,7 @@ let expand_mrdq conn queue =
|
||||||
| other -> Node.name_of_string other
|
| other -> Node.name_of_string other
|
||||||
|
|
||||||
let handle_method conn channel m =
|
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 ();
|
if channel > 1 then die channel_error "Unsupported channel number" else ();
|
||||||
match m with
|
match m with
|
||||||
| Connection_close (code, text, _, _) ->
|
| Connection_close (code, text, _, _) ->
|
||||||
|
|
Loading…
Reference in New Issue