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 | 771097544ac3dc9e8491a948db0e20a7794910a0 (patch) | |
| tree | 02e4aadd44d81eb721b47321993ad5e2027e663a | |
| parent | 692f208182134783e02a98bd2c80b5d1191e500c (diff) | |
| download | rabbitmq-server-git-771097544ac3dc9e8491a948db0e20a7794910a0.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 0544d32e6a..0f8266dc46 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}, |