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 | 299c60ac89f6a1cdb8025101eb2ab7d8fdf0f1fd (patch) | |
| tree | 9490c5a27fe7bd4fbb2f27f5f96b1dcfea982355 | |
| parent | a84071c5f1dbe8a9ffe576fac5e01161c92b4202 (diff) | |
| download | rabbitmq-server-299c60ac89f6a1cdb8025101eb2ab7d8fdf0f1fd.tar.gz | |
Honour the requeue flag in basic.nack
| -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 1ad92318..a56615a9 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}, |