summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2011-10-21 19:07:58 +0100
committerMatthias Radestock <matthias@rabbitmq.com>2011-10-21 19:07:58 +0100
commit1a126a457c74b1e2fc45d13af9b993dbb31936f3 (patch)
tree24a35c79b73022287850373965d81fb54d8e3c7a /src
parentca0a3fe5b462f8029ee6c3252b8b889b019f2418 (diff)
downloadrabbitmq-server-git-1a126a457c74b1e2fc45d13af9b993dbb31936f3.tar.gz
eliminate unused var warning
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_amqqueue_process.erl11
1 files changed, 5 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index 81347cf74a..ec1a9b778d 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -551,12 +551,11 @@ deliver_or_enqueue(Delivery = #delivery{message = Message,
ensure_ttl_timer(State2#q{backing_queue_state = BQS1})
end.
-requeue_and_run(AckTags, State = #q{backing_queue = BQ, ttl=TTL}) ->
- run_backing_queue(
- BQ, fun (M, BQS) ->
- {_MsgIds, BQS1} = M:requeue(AckTags, BQS),
- BQS1
- end, State).
+requeue_and_run(AckTags, State = #q{backing_queue = BQ}) ->
+ run_backing_queue(BQ, fun (M, BQS) ->
+ {_MsgIds, BQS1} = M:requeue(AckTags, BQS),
+ BQS1
+ end, State).
fetch(AckRequired, State = #q{backing_queue_state = BQS,
backing_queue = BQ}) ->