diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index cba1dbc30c..4f9666c7f3 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -780,8 +780,8 @@ update_rate(Now, Then, Count, {OThen, OCount}) -> Avg = 1000000 * ((Count + OCount) / timer:now_diff(Now, OThen)), {Avg, {Then, Count}}. -persistent_guids(Pubs) -> [Guid || Obj = #basic_message { guid = Guid } <- Pubs, - Obj #basic_message.is_persistent]. +persistent_guids(Pubs) -> + [Guid || #basic_message { guid = Guid, is_persistent = true } <- Pubs]. betas_from_segment_entries(List, TransientThreshold, IndexState) -> {Filtered, IndexState1} = |