syndicate-lang
/
hop-2012
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Ignore received Channel_close_ok

This commit is contained in:
Tony Garnock-Jones 2012-03-05 16:55:36 -05:00
parent f159347646
commit dbe0124314
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
amqp_relay.ml
View File

@ -247,6 +247,8 @@ let handle_method conn channel m =
| Channel_close (code, text, _, _) -> | Channel_close (code, text, _, _) ->
Log.info "Client closed AMQP channel" [Sexp.Str (string_of_int code); Sexp.Str text]; Log.info "Client closed AMQP channel" [Sexp.Str (string_of_int code); Sexp.Str text];
send_method conn channel Channel_close_ok; send_method conn channel Channel_close_ok;
| Channel_close_ok ->
()
| Exchange_declare (exchange, type_, passive, durable, no_wait, arguments) -> | Exchange_declare (exchange, type_, passive, durable, no_wait, arguments) ->
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],