Supports, using prefetch.
For ruby code will be something like this:
\r
\r
mq_conn = AMQP.connect mq = MQ.new(mq_conn).prefetch(100) mq.queue("queue").subscribe do |header, message| # processing... end However it does not regulate the upload speed, but the message recipient will be sent a batch of 100 pieces. Therefore, if multiple recipients, the 1000 messages will be sent between portions of 100 pieces.
\r
If you want exactly 100 messages per second, you apparently need to manually use .pop with the desired interval.