@@ -2810,8 +2810,8 @@ get_queue_consumer_timeout(_PA = #pending_ack{queue = QName},
28102810 {ok , Q } -> % % should we account for different queue states here?
28112811 case rabbit_queue_type_util :args_policy_lookup (<<" consumer-timeout" >>,
28122812 fun (X , Y ) -> erlang :min (X , Y ) end , Q ) of
2813- undefined -> GCT ;
2814- Val -> Val
2813+ undefined -> GCT ;
2814+ Val -> Val
28152815 end ;
28162816 _ ->
28172817 GCT
@@ -2822,18 +2822,18 @@ get_consumer_timeout(PA = #pending_ack{tag = CTag},
28222822 case maps :find (CTag , CMap ) of
28232823 {ok , {_ , {_ , _ , _ , Args }}} ->
28242824 case rabbit_misc :table_lookup (Args , <<" x-consumer-timeout" >>) of
2825- {long , Timeout } -> Timeout ;
2826- _ -> get_queue_consumer_timeout (PA , State )
2825+ {long , Timeout } -> Timeout ;
2826+ _ -> get_queue_consumer_timeout (PA , State )
28272827 end ;
28282828 _ ->
28292829 get_queue_consumer_timeout (PA , State )
28302830 end .
28312831
28322832evaluate_consumer_timeout (State = # ch {unacked_message_q = UAMQ }) ->
28332833 case ? QUEUE :get (UAMQ , empty ) of
2834- empty ->
2835- {noreply , State };
2836- PA -> evaluate_consumer_timeout1 (PA , State )
2834+ empty ->
2835+ {noreply , State };
2836+ PA -> evaluate_consumer_timeout1 (PA , State )
28372837 end .
28382838
28392839evaluate_consumer_timeout1 (PA = # pending_ack {delivered_at = Time },
0 commit comments