diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-09-12 17:36:10 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-09-12 17:36:10 +0100 |
| commit | 0aff23ef73ab7f2e480d63da58031298d500ddc4 (patch) | |
| tree | a074df473d1dc1a5a82be0f9a38bac0171d00210 /src | |
| parent | b00cdc01b3ce7cd3fad9fdeed3230de8677aab17 (diff) | |
| download | rabbitmq-server-git-0aff23ef73ab7f2e480d63da58031298d500ddc4.tar.gz | |
exchange.unbind has nowait
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 0613422c30..08b16f69f7 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -727,10 +727,11 @@ handle_method(#'exchange.bind'{destination = DestinationNameBin, handle_method(#'exchange.unbind'{destination = DestinationNameBin, source = SourceNameBin, routing_key = RoutingKey, + nowait = NoWait, arguments = Arguments}, _, State) -> binding_action(fun rabbit_binding:remove/2, SourceNameBin, exchange, DestinationNameBin, RoutingKey, - Arguments, #'exchange.unbind_ok'{}, false, State); + Arguments, #'exchange.unbind_ok'{}, NoWait, State); handle_method(#'queue.declare'{queue = QueueNameBin, passive = false, |