diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 1 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 1 |
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; |
