Skip to content

add send queue size limit to resolve message backlog.#25

Open
LeoYang06 wants to merge 1 commit intoqicosmos:masterfrom
LeoYang06:fix_pub_sub_message_backlog
Open

add send queue size limit to resolve message backlog.#25
LeoYang06 wants to merge 1 commit intoqicosmos:masterfrom
LeoYang06:fix_pub_sub_message_backlog

Conversation

@LeoYang06
Copy link
Copy Markdown

  • add a function to get the size of the send queue.
  • add the maximum size parameter of the send queue, limit the length of the send queue, and discard the latest message beyond the queue limit.

@qicosmos
Copy link
Copy Markdown
Owner

还可以增加达到上限的一个回调,回调给用户,让用户有机会做反压的处理。

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants