diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-04-23 14:34:52 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-04-23 14:36:10 +0100 |
| commit | 23fd689fb96bd67f3dcde961b1e3a42c4a2b608f (patch) | |
| tree | 572317b466fbf52841f8ce28ee1b4ce02db3cc02 /src | |
| parent | 08f7e23527530ec771b38db3f711a43b192ed673 (diff) | |
| download | rabbitmq-server-git-23fd689fb96bd67f3dcde961b1e3a42c4a2b608f.tar.gz | |
spelling
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_channel.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index b9f842e9e9..ff6186ad84 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -834,7 +834,7 @@ handle_info(tick, State0 = #ch{queue_states = QueueStates0}) -> QName = rabbit_quorum_queue:queue_name(QS), [] /= rabbit_amqqueue:lookup([QName]) end, QueueStates0), - case evalauate_consumer_timeout(State0#ch{queue_states = QueueStates1}) of + case evaluate_consumer_timeout(State0#ch{queue_states = QueueStates1}) of {noreply, State} -> noreply(init_tick_timer(reset_tick_timer(State))); Return -> @@ -2703,12 +2703,12 @@ queue_fold(Fun, Init, Q) -> {{value, V}, Q1} -> queue_fold(Fun, Fun(V, Init), Q1) end. -evalauate_consumer_timeout(State0 = #ch{cfg = #conf{channel = Channel, - capabilities = Capabilities, - consumer_timeout = Timeout}, - queue_names = QNames, - queue_consumers = QCons, - unacked_message_q = UAMQ}) -> +evaluate_consumer_timeout(State0 = #ch{cfg = #conf{channel = Channel, + capabilities = Capabilities, + consumer_timeout = Timeout}, + queue_names = QNames, + queue_consumers = QCons, + unacked_message_q = UAMQ}) -> Now = os:system_time(millisecond), case ?QUEUE:peek(UAMQ) of {value, {_DTag, ConsumerTag, Time, {QPid, _Msg}}} |