Expose prefetch in Connection.consume

ScalaConsultants / reactive-rabbit

Reactive Streams driver for AMQP protocol. Powered by RabbitMQ library.

Apache License 2.0

184 stars 40 forks source link

Expose prefetch in Connection.consume #21

Closed mkiedys closed 8 years ago

mkiedys commented 8 years ago

This change allows consumers to decide how many messages they want to prefetch from the queue. Default settings is 20. Prefetched messages are acknowledged one by one upon delivery.

Related: #20

mkiedys commented 8 years ago

@zackangelo Let me know what you think about this. This can be also done at configuration level.

moliware commented 8 years ago

:+1:
It would be nice to have this merged :) Thanks!