@@ -632,22 +632,19 @@ handle_consumer_removal(Group0, Consumer, Stream, ConsumerName) ->
632
632
notify_consumer_effect (Pid , SubId , Stream , Name , Active ) ->
633
633
notify_consumer_effect (Pid , SubId , Stream , Name , Active , false ).
634
634
635
- notify_consumer_effect (Pid , SubId , Stream , Name , Active , SteppingDown ) ->
636
- notify_consumer_effect (Pid , SubId , Stream , Name , Active , SteppingDown , map ).
637
-
638
- notify_consumer_effect (Pid , SubId , Stream , Name , Active , false = _SteppingDown , map ) ->
635
+ notify_consumer_effect (Pid , SubId , Stream , Name , Active , false = _SteppingDown ) ->
639
636
mod_call_effect (Pid ,
640
637
{sac , #{subscription_id => SubId ,
641
638
stream => Stream ,
642
639
consumer_name => Name ,
643
640
active => Active }});
644
- notify_consumer_effect (Pid , SubId , Stream , Name , Active , true = _SteppingDown , map ) ->
641
+ notify_consumer_effect (Pid , SubId , Stream , Name , Active , true = SteppingDown ) ->
645
642
mod_call_effect (Pid ,
646
643
{sac , #{subscription_id => SubId ,
647
644
stream => Stream ,
648
645
consumer_name => Name ,
649
646
active => Active ,
650
- stepping_down => true }}).
647
+ stepping_down => SteppingDown }}).
651
648
652
649
maybe_create_group (VirtualHost ,
653
650
Stream ,
0 commit comments