summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mirror_queue_master.erl1
-rw-r--r--src/rabbit_mirror_queue_slave.erl1
2 files changed, 0 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl
index 78c771cc9c..1d2b1676cf 100644
--- a/src/rabbit_mirror_queue_master.erl
+++ b/src/rabbit_mirror_queue_master.erl
@@ -65,7 +65,6 @@ sender_death_fun() ->
rabbit_amqqueue:run_backing_queue_async(
Self, ?MODULE,
fun (?MODULE, State = #state { gm = GM, known_senders = KS }) ->
- rabbit_log:info("Master saw death of sender ~p~n", [DeadPid]),
ok = gm:broadcast(GM, {sender_death, DeadPid}),
KS1 = sets:del_element(DeadPid, KS),
State #state { known_senders = KS1 }
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl
index 265657de96..5c0730dda8 100644
--- a/src/rabbit_mirror_queue_slave.erl
+++ b/src/rabbit_mirror_queue_slave.erl
@@ -819,7 +819,6 @@ process_instruction({requeue, MsgPropsFun, MsgIds},
process_instruction({sender_death, ChPid},
State = #state { sender_queues = SQ,
known_senders = KS }) ->
- rabbit_log:info("Slave received death of sender ~p~n", [ChPid]),
{ok, case dict:find(ChPid, KS) of
error ->
State;