bitcapybara/budmq

add cache for published messages

Opened this issue · 1 comments

bitcapybara commented

cache the messages in broker, used to send consumer instantly

bitcapybara commented

fixed size hashmap

  • retain oldest messages in fiexed size
  • add_message: insert into map only if map not full
  • get_message: if message not found, load newer message from storage until map is full