xing/beetle

make it possible to specify prefetch size for queues

skaes opened this issue · 2 comments

setting prefetch size to something greater than 1 would increase throughput on the subscriber side.

the value could be specified as part of the queue declaration/binding process.

note that stopping a subscriber with a non empty prefetch buffer would lead to messages being reordered in the queue on the broker.

eric commented

I would love to see this.

skaes commented

Implemented in c57845c