diff options
| author | Rob Harrop <rob@rabbitmq.com> | 2011-01-12 09:20:52 +0000 |
|---|---|---|
| committer | Rob Harrop <rob@rabbitmq.com> | 2011-01-12 09:20:52 +0000 |
| commit | c0ea9e0595049cc91c1cd32f108c6ebdf85ce3ce (patch) | |
| tree | 9490c5a27fe7bd4fbb2f27f5f96b1dcfea982355 /src | |
| parent | 2be3dddb891f6edec591e8e69742b30063719d55 (diff) | |
| download | rabbitmq-server-git-c0ea9e0595049cc91c1cd32f108c6ebdf85ce3ce.tar.gz | |
Honour the requeue flag in basic.nack
Diffstat (limited to 'src')
| -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 1ad92318f8..a56615a9b1 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -569,9 +569,10 @@ handle_method(#'basic.publish'{exchange = ExchangeNameBin, end}; handle_method(#'basic.nack'{delivery_tag = DeliveryTag, - multiple = Multiple}, + multiple = Multiple, + requeue = Requeue}, _, State) -> - reject(DeliveryTag, true, Multiple, State); + reject(DeliveryTag, Requeue, Multiple, State); handle_method(#'basic.ack'{delivery_tag = DeliveryTag, multiple = Multiple}, |