Skip to content

Commit 59a9671

Browse files
committed
CQ: Remove an unused {requeue,...} handle_call clause
Requeue is handled asynchronously so this clause is unused.
1 parent 50e74d8 commit 59a9671

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

deps/rabbit/src/rabbit_amqqueue_process.erl

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1466,11 +1466,7 @@ handle_call(purge, _From, State = #q{backing_queue = BQ,
14661466
backing_queue_state = BQS}) ->
14671467
{Count, BQS1} = BQ:purge(BQS),
14681468
State1 = State#q{backing_queue_state = BQS1},
1469-
reply({ok, Count}, notify_decorators_if_became_empty(Count =:= 0, State1));
1470-
1471-
handle_call({requeue, AckTags, ChPid}, From, State) ->
1472-
gen_server2:reply(From, ok),
1473-
noreply(requeue(AckTags, ChPid, State)).
1469+
reply({ok, Count}, notify_decorators_if_became_empty(Count =:= 0, State1)).
14741470

14751471
new_single_active_consumer_after_basic_cancel(ChPid, ConsumerTag, CurrentSingleActiveConsumer,
14761472
_SingleActiveConsumerIsOn = true, Consumers) ->

0 commit comments

Comments
 (0)