rabbitmq/rabbitmq-server#1382

consume

#!/usr/bin/env ruby
# encoding: utf-8

require 'bunny'
require 'glutton_ratelimit'
require 'pp'

conn = Bunny.new
conn.start
ch  = conn.create_channel
q = ch.queue('gh-1382')
puts "Consuming..."
# maximum of five executions every five seconds
rl = GluttonRatelimit::AveragedThrottle.new 8, 2
rl.times(16384) do
  delivery_info, properties, payload = q.pop
  pp properties
end

publish

#!/usr/bin/env ruby
# encoding: utf-8

require 'bunny'
require 'sysrandom'
require 'glutton_ratelimit'

b = Bunny.new.start
ch = b.create_channel
q = ch.queue('gh-1382')
puts q.name
msg = Sysrandom.base64(1024 * 1024 * 4)

# maximum of five executions every five seconds
rl = GluttonRatelimit::AveragedThrottle.new 5, 1
rl.times(16384) do
  q.publish msg
end

test.config

% vim:ft=erlang:

[
  {rabbit, [
      {loopback_users, []},
      {vm_memory_high_watermark, 0.05}
    ]}
].