From 1d003a4fda28a781103760505f81d4227f4f9fd5 Mon Sep 17 00:00:00 2001
From: Andrei Zavada <andrei.zavada@tiot.jp>
Date: Wed, 23 Nov 2022 04:19:01 +0200
Subject: [PATCH] rebase oops

---
 src/riak_kv_replrtq_src.erl | 17 -----------------
 1 file changed, 17 deletions(-)

diff --git a/src/riak_kv_replrtq_src.erl b/src/riak_kv_replrtq_src.erl
index 9ec0f6208..b029685d5 100644
--- a/src/riak_kv_replrtq_src.erl
+++ b/src/riak_kv_replrtq_src.erl
@@ -335,23 +335,6 @@ init([FilePath]) ->
 
     {OL, QL} = get_limits(),
 
-    MapToQOverflow =
-        fun({QueueName, _QF, _QA}) ->
-            {QueueName, empty_overflow_queue(QueueName, FilePath)}
-        end,
-    MaptoQCache =
-        fun({QueueName, _QF, _QA}) ->
-            {QueueName, empty_local_queue()}
-        end,
-    QO = lists:map(MapToQOverflow, QFM),
-    QC = lists:map(MaptoQCache, QFM),
-    LogFreq =
-        app_helper:get_env(
-            riak_kv,
-            replrtq_logfrequency,
-            ?LOG_TIMER_SECONDS * 1000),
-    erlang:send_after(LogFreq, self(), log_queue),
-
     {ok, #state{queue_filtermap = QFM,
                 queue_overflow = QO,
                 queue_local = QC,