Introduce `max_concurrent_consumed_messages`: stop reading when threshold is reached on slow consumer callbacks#135

Merged

vrslev merged 11 commits intomainfrom

message-frame-buf

Aug 7, 2025

Commits on Aug 7, 2025

Introduce message frame queue and separate message processing task to decouple frame listening and handling logic.
vrslev
committed
Add task_done call on invalid subscription in message handling loop
vrslev
committed
Add message frames buffer size and initialize message queue with it in Client class
vrslev
committed
Implement concurrency control for message processing using semaphore to limit parallel execution
vrslev
committed
Handle cancelled listen task gracefully
vrslev
committed
Update message frame processing to avoid redundant semaphore release logic and simplify task creation.
vrslev
committed
Improve message handling by adding a publisher and restructuring subscription logic in example, rename config parameter to clarify concurrency limit
vrslev
committed
Merge branch 'main' into message-frame-buf
vrslev
committed
Add noqa comment to print statements in STOMP broadcast example
vrslev
committed
Rename max_concurrent_messages_limit to max_concurrent_consumed_messages for clarity
vrslev
committed
Add max_concurrent_consumed_messages configuration to client example
vrslev
committed