bunnyrun/examples/basic-consumers-example/ping_consumer.rb

require 'bunnyrun'

class PingConsumer < BunnyRun::Consumer
  queue 'ping'

  exchange 'ping-pong', type: :direct
  bind 'ping-pong', routing_key: 'ping'

  manual_ack true # default is false

  def perform(message)
    logger.info "#{self.class} received: #{message.payload}"
    sleep 1

    publish('ping-pong', 'PONG', routing_key: 'pong')
    message.ack
  end
end