Support no_wait for Exchange_declare
This commit is contained in:
parent
215d869b51
commit
8d893ebbee
|
@ -288,10 +288,15 @@ let handle_method conn channel m =
|
||||||
then return ()
|
then return ()
|
||||||
else send_method conn channel Exchange_declare_ok
|
else send_method conn channel Exchange_declare_ok
|
||||||
| Exchange_declare (exchange, type_, passive, durable, no_wait, arguments) ->
|
| Exchange_declare (exchange, type_, passive, durable, no_wait, arguments) ->
|
||||||
|
let (reply_sink, reply_name) =
|
||||||
|
if no_wait
|
||||||
|
then ("", "")
|
||||||
|
else (conn.name.Node.label, "Exchange_declare_reply")
|
||||||
|
in
|
||||||
Node.send_ignore' "factory" (Message.create (Sexp.Str type_,
|
Node.send_ignore' "factory" (Message.create (Sexp.Str type_,
|
||||||
Sexp.Arr [Sexp.Str exchange],
|
Sexp.Arr [Sexp.Str exchange],
|
||||||
Sexp.Str conn.name.Node.label,
|
Sexp.Str reply_sink,
|
||||||
Sexp.Str "Exchange_declare_reply"))
|
Sexp.Str reply_name))
|
||||||
| Queue_declare (queue, passive, durable, exclusive, auto_delete, no_wait, arguments) ->
|
| Queue_declare (queue, passive, durable, exclusive, auto_delete, no_wait, arguments) ->
|
||||||
let queue = (if queue = "" then Uuid.create () else queue) in
|
let queue = (if queue = "" then Uuid.create () else queue) in
|
||||||
conn.recent_queue_name <- Some (Node.name_of_string queue);
|
conn.recent_queue_name <- Some (Node.name_of_string queue);
|
||||||
|
|
Loading…
Reference in New Issue