@@ -247,8 +247,6 @@ apply(#command_activate_consumer{vhost = VirtualHost,
247
247
stream = Stream ,
248
248
consumer_name = ConsumerName },
249
249
#? MODULE {groups = StreamGroups0 } = State0 ) ->
250
- rabbit_log :debug (" Activating consumer on ~tp , group ~p " ,
251
- [Stream , ConsumerName ]),
252
250
{G , Eff } =
253
251
case lookup_group (VirtualHost , Stream , ConsumerName , StreamGroups0 ) of
254
252
undefined ->
@@ -259,11 +257,7 @@ apply(#command_activate_consumer{vhost = VirtualHost,
259
257
Group ->
260
258
# consumer {pid = Pid , subscription_id = SubId } =
261
259
evaluate_active_consumer (Group ),
262
- rabbit_log :debug (" New active consumer on ~tp , group ~tp " ++
263
- " is ~tp from ~tp " ,
264
- [Stream , ConsumerName , SubId , Pid ]),
265
- Group1 =
266
- update_consumer_state_in_group (Group , Pid , SubId , true ),
260
+ Group1 = update_consumer_state_in_group (Group , Pid , SubId , true ),
267
261
{Group1 , [notify_consumer_effect (Pid , SubId , Stream , ConsumerName , true )]}
268
262
end ,
269
263
StreamGroups1 =
@@ -553,10 +547,6 @@ do_register_consumer(VirtualHost,
553
547
% % the current active stays the same
554
548
{G1 , []};
555
549
_ ->
556
- rabbit_log :debug (" SAC consumer registration: " ++
557
- " active consumer change on stream ~tp , group ~tp . " ++
558
- " Notifying ~tp from ~tp it is no longer active." ,
559
- [Stream , ConsumerName , ActSubId , ActPid ]),
560
550
% % there's a change, telling the active it's not longer active
561
551
{update_consumer_state_in_group (G1 ,
562
552
ActPid ,
@@ -570,9 +560,6 @@ do_register_consumer(VirtualHost,
570
560
true )]}
571
561
end ;
572
562
false ->
573
- rabbit_log :debug (" SAC consumer registration: no active consumer on stream ~tp , group ~tp . " ++
574
- " Likely waiting for a response from former active consumer." ,
575
- [Stream , ConsumerName ]),
576
563
% % no active consumer in the (non-empty) group,
577
564
% % we are waiting for the reply of a former active
578
565
{G1 , []}
@@ -618,11 +605,6 @@ handle_consumer_removal(Group0, Consumer, Stream, ConsumerName) ->
618
605
% % the current active stays the same
619
606
{Group0 , []};
620
607
_ ->
621
- rabbit_log :debug (" SAC consumer removal: " ++
622
- " active consumer change on stream ~tp , group ~tp . " ++
623
- " Notifying ~tp from ~tp it is no longer active." ,
624
- [Stream , ConsumerName , ActSubId , ActPid ]),
625
-
626
608
% % there's a change, telling the active it's not longer active
627
609
{update_consumer_state_in_group (Group0 ,
628
610
ActPid ,
@@ -637,17 +619,10 @@ handle_consumer_removal(Group0, Consumer, Stream, ConsumerName) ->
637
619
% % the active one is going away, picking a new one
638
620
# consumer {pid = P , subscription_id = SID } =
639
621
evaluate_active_consumer (Group0 ),
640
- rabbit_log :debug (" SAC consumer removal: " ++
641
- " active consumer change on stream ~tp , group ~tp . " ++
642
- " Notifying ~tp from ~tp it is the new active consumer." ,
643
- [Stream , ConsumerName , SID , P ]),
644
622
{update_consumer_state_in_group (Group0 , P , SID , true ),
645
623
[notify_consumer_effect (P , SID ,
646
624
Stream , ConsumerName , true )]};
647
625
false ->
648
- rabbit_log :debug (" SAC consumer removal: no active consumer on stream ~tp , group ~tp . " ++
649
- " Likely waiting for a response from former active consumer." ,
650
- [Stream , ConsumerName ]),
651
626
% % no active consumer in the (non-empty) group,
652
627
% % we are waiting for the reply of a former active
653
628
{Group0 , []}
0 commit comments