diff options
| author | tomyouyou <yxszyn@163.com> | 2019-09-04 11:51:08 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-09-04 11:51:08 +0800 |
| commit | dc2552b682633660b75e8b945398f4d6f29ccc32 (patch) | |
| tree | 924fd9e63c79c4819cc3e4a1b9bd1050b861b806 /priv/schema | |
| parent | 133d261ad615d377060c2b6ca0deaa262f109ed9 (diff) | |
| download | rabbitmq-server-git-dc2552b682633660b75e8b945398f4d6f29ccc32.tar.gz | |
call "add_to_journal" before "maybe_flush_pre_publish_cache"
To reproduce the issue:
1. pre_publish a delivered message.
2. Put its SeqId into delivered_cache, and might call "flush_pre_publish_cache" and "flush_delivered_cache",
then put its "del" data into the journal_entries of the corresponding segment.
3. Call add_to_journal and action_to_entry with a "?PUB" Action.
4. in action_to_entry, "array:get(RelSeq, JEntries)" will return {no_pub, del, no_ack}, but has none case for a "?PUB" Action, so an error will occur like "{{case_clause,{no_pub,del,no_ack}},[{rabbit_queue_index,action_to_entry,3..."
Diffstat (limited to 'priv/schema')
0 files changed, 0 insertions, 0 deletions
