diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-08-08 17:21:11 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-08-08 17:21:11 +0100 |
| commit | 6826eaefc4cb212b0faeb152ec6d2ba1203802cf (patch) | |
| tree | d22dd777435e20d59730aee4e40af1edf4698ebf /src | |
| parent | 14191a156a4be97d87dae99bae3b88d196d9f4e0 (diff) | |
| download | rabbitmq-server-git-6826eaefc4cb212b0faeb152ec6d2ba1203802cf.tar.gz | |
Upgrade all entries in a segment
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_queue_index.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 6388da8f79..636913b5c8 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -1013,7 +1013,7 @@ add_queue_ttl_segment(<<?PUB_PREFIX:?PUB_PREFIX_BITS, IsPersistentNum:1, {[<<?PUB_PREFIX:?PUB_PREFIX_BITS, IsPersistentNum:1, RelSeq:?REL_SEQ_BITS>>, MsgId, expiry_to_binary(undefined)], Rest}; add_queue_ttl_segment(<<?REL_SEQ_ONLY_PREFIX:?REL_SEQ_ONLY_PREFIX_BITS, - RelSeq:?REL_SEQ_BITS, Rest>>) -> + RelSeq:?REL_SEQ_BITS, Rest/binary>>) -> {<<?REL_SEQ_ONLY_PREFIX:?REL_SEQ_ONLY_PREFIX_BITS, RelSeq:?REL_SEQ_BITS>>, Rest}; add_queue_ttl_segment(_) -> |