Cosmetic improvement to error messages
This commit is contained in:
parent
8d893ebbee
commit
5f250c7f90
|
@ -312,7 +312,7 @@ let handle_method conn channel m =
|
||||||
| Queue_bind (queue, exchange, routing_key, no_wait, arguments) ->
|
| Queue_bind (queue, exchange, routing_key, no_wait, arguments) ->
|
||||||
let queue = expand_mrdq conn queue in
|
let queue = expand_mrdq conn queue in
|
||||||
if not (Node.approx_exists queue)
|
if not (Node.approx_exists queue)
|
||||||
then send_warning conn not_found ("Queue "^queue.Node.label^" not found")
|
then send_warning conn not_found ("Queue '"^queue.Node.label^"' not found")
|
||||||
else
|
else
|
||||||
(match_lwt Node.send' exchange (Message.subscribe (Sexp.Str routing_key,
|
(match_lwt Node.send' exchange (Message.subscribe (Sexp.Str routing_key,
|
||||||
Sexp.Str queue.Node.label,
|
Sexp.Str queue.Node.label,
|
||||||
|
@ -320,7 +320,7 @@ let handle_method conn channel m =
|
||||||
Sexp.Str conn.name.Node.label,
|
Sexp.Str conn.name.Node.label,
|
||||||
Sexp.Str "Queue_bind_reply")) with
|
Sexp.Str "Queue_bind_reply")) with
|
||||||
| true -> return ()
|
| true -> return ()
|
||||||
| false -> send_warning conn not_found ("Exchange "^exchange^" not found"))
|
| false -> send_warning conn not_found ("Exchange '"^exchange^"' not found"))
|
||||||
| Basic_consume (queue, consumer_tag, no_local, no_ack, exclusive, no_wait, arguments) ->
|
| Basic_consume (queue, consumer_tag, no_local, no_ack, exclusive, no_wait, arguments) ->
|
||||||
let queue = expand_mrdq conn queue in
|
let queue = expand_mrdq conn queue in
|
||||||
let consumer_tag = (if consumer_tag = "" then Uuid.create () else consumer_tag) in
|
let consumer_tag = (if consumer_tag = "" then Uuid.create () else consumer_tag) in
|
||||||
|
@ -332,7 +332,7 @@ let handle_method conn channel m =
|
||||||
Sexp.Arr [Sexp.Str "Basic_consume_reply";
|
Sexp.Arr [Sexp.Str "Basic_consume_reply";
|
||||||
Sexp.Str consumer_tag])) with
|
Sexp.Str consumer_tag])) with
|
||||||
| true -> return ()
|
| true -> return ()
|
||||||
| false -> send_warning conn not_found ("Queue "^queue.Node.label^" not found"))
|
| false -> send_warning conn not_found ("Queue '"^queue.Node.label^"' not found"))
|
||||||
| Basic_publish (exchange, routing_key, false, false) ->
|
| Basic_publish (exchange, routing_key, false, false) ->
|
||||||
lwt (_, (body_size, properties)) = next_header conn in
|
lwt (_, (body_size, properties)) = next_header conn in
|
||||||
lwt body = recv_content_body conn body_size in
|
lwt body = recv_content_body conn body_size in
|
||||||
|
|
Loading…
Reference in New Issue