File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -1375,7 +1375,12 @@ is_v4() ->
13751375
13761376messages_ready (#? STATE {messages = M ,
13771377 returns = R }) ->
1378- rabbit_fifo_q :len (M ) + lqueue :len (R ).
1378+ case is_v4 () of
1379+ true ->
1380+ rabbit_fifo_q :len (M ) + lqueue :len (R );
1381+ false ->
1382+ lqueue :len (M ) + lqueue :len (R )
1383+ end .
13791384
13801385messages_total (#? STATE {messages_total = Total ,
13811386 dlx = DlxState }) ->
@@ -1547,7 +1552,7 @@ activate_next_consumer(#?STATE{consumers = Cons0,
15471552 waiting_consumers = Waiting },
15481553 Effects1 = consumer_update_active_effects (State , Active ,
15491554 false , waiting ,
1550- Effects0 ),
1555+ Effects0 ),
15511556 Effects = consumer_update_active_effects (State , Consumer ,
15521557 true , single_active ,
15531558 Effects1 ),
You can’t perform that action at this time.
0 commit comments