You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Is there any plans to allow configuring the 'pendingMessages' LinkedBlockingQueue capacity?
I think it would be nice to have such possibility to prevent excessive queue expansion when producer thread puts more elements than the consumer consumes.
The text was updated successfully, but these errors were encountered:
Yes, I think that's a valid requirement. I'm going to introduce a configuration object to hold all configurable properties and provide a corresponding constructor. I could integrate a parameter for the queue capacity or even make the queue a configurable parameter. Maybe that would be the better choice as this allows for different queuing strategies (although it also introduces a new source for bugs but that's responsibility of the user then).
Hello,
Is there any plans to allow configuring the 'pendingMessages' LinkedBlockingQueue capacity?
I think it would be nice to have such possibility to prevent excessive queue expansion when producer thread puts more elements than the consumer consumes.
The text was updated successfully, but these errors were encountered: