module BunnyHop::ControllerHelper

Public Instance Methods

on(queue) { |payload| ... } click to toggle source
# File lib/bunny_hop.rb, line 62
def on(queue)
  @__bunny ||= BunnyHop.new
  puts "subscribe to #{queue}"
  @__bunny.subscribe(queue.to_s) do |payload|
    yield(payload)
  end
end