diff options
| author | Tony Garnock-Jones <tonyg@lshift.net> | 2008-10-31 11:36:49 +0000 |
|---|---|---|
| committer | Tony Garnock-Jones <tonyg@lshift.net> | 2008-10-31 11:36:49 +0000 |
| commit | 7142aac483c1e4aef4ea8b61ba16cb80c8477656 (patch) | |
| tree | 02e4aadd44d81eb721b47321993ad5e2027e663a | |
| parent | 5f27090c4fdc0239aa3c0a933cdfad9621eb57e4 (diff) | |
| download | rabbitmq-server-7142aac483c1e4aef4ea8b61ba16cb80c8477656.tar.gz | |
Alter signatures to the latest 0-91 draft XML, and support nowait
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 0544d32e..0f8266dc 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -580,10 +580,11 @@ handle_method(#'queue.bind'{queue = QueueNameBin, handle_method(#'queue.unbind'{queue = QueueNameBin, exchange = ExchangeNameBin, routing_key = RoutingKey, - arguments = Arguments}, _, State) -> + arguments = Arguments, + nowait = NoWait}, _, State) -> binding_action(fun rabbit_amqqueue:delete_binding/4, ExchangeNameBin, QueueNameBin, RoutingKey, Arguments, #'queue.unbind_ok'{}, - false, State); + NoWait, State); handle_method(#'queue.purge'{queue = QueueNameBin, nowait = NoWait}, |