summaryrefslogtreecommitdiff
path: root/priv/schema
diff options
context:
space:
mode:
authortomyouyou <yxszyn@163.com>2019-09-04 11:51:08 +0800
committerGitHub <noreply@github.com>2019-09-04 11:51:08 +0800
commitdc2552b682633660b75e8b945398f4d6f29ccc32 (patch)
tree924fd9e63c79c4819cc3e4a1b9bd1050b861b806 /priv/schema
parent133d261ad615d377060c2b6ca0deaa262f109ed9 (diff)
downloadrabbitmq-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