From dbe0124314ff0f8c28953ee6d8244710de83fa66 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Mon, 5 Mar 2012 16:55:36 -0500 Subject: [PATCH] Ignore received Channel_close_ok --- amqp_relay.ml | 2 ++ 1 file changed, 2 insertions(+) diff --git a/amqp_relay.ml b/amqp_relay.ml index e69f800..95ecdfe 100644 --- a/amqp_relay.ml +++ b/amqp_relay.ml @@ -247,6 +247,8 @@ let handle_method conn channel m = | Channel_close (code, text, _, _) -> Log.info "Client closed AMQP channel" [Sexp.Str (string_of_int code); Sexp.Str text]; send_method conn channel Channel_close_ok; + | Channel_close_ok -> + () | Exchange_declare (exchange, type_, passive, durable, no_wait, arguments) -> Node.send_ignore "factory" (Message.create (Sexp.Str type_, Sexp.Arr [Sexp.Str exchange],