search

amqp / rhea

A reactive messaging library based on the AMQP protocol
Apache License 2.0
273 stars 80 forks source link

Customizable Session Incoming and Outgoing CircularBuffer size #400

Closed MarioArnt closed 1 year ago

MarioArnt commented 1 year ago

Hi,

I needed to change these parameters and saw a TODO annotation in the current code 👍

Here is a PR allowing to customize these size by giving an optional additional ConnectionOptions.

Your feedback is very welcome 😄

Have a great day

grs commented 1 year ago

Thank you @MarioArnt !