diff options
Diffstat (limited to 'src/rabbit_variable_queue.erl')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index a0f14b0a..8a1e52cf 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1414,7 +1414,7 @@ determine_persist_to(Msg, #message_properties{size = Size}) -> %% anyway. case Size >= IndexMaxSize of true -> msg_store; - false -> case size(term_to_binary(Msg)) >= IndexMaxSize of + false -> case truncate:term_limit(Msg, IndexMaxSize) of true -> msg_store; false -> queue_index end |