class Burrow::Connection

Attributes

queue_name[R]

Public Class Methods

new(queue_name) click to toggle source
# File lib/burrow/connection.rb, line 5
def initialize(queue_name)
  @queue_name = queue_name
end

Public Instance Methods

channel() click to toggle source
# File lib/burrow/connection.rb, line 17
def channel
  @channel ||= connection.create_channel
end
connection() click to toggle source
# File lib/burrow/connection.rb, line 9
def connection
  @connection ||= begin
    c = Bunny.new
    c.start
    c
  end
end
exchange() click to toggle source
# File lib/burrow/connection.rb, line 25
def exchange
  @exchange ||= channel.default_exchange
end
queue() click to toggle source
# File lib/burrow/connection.rb, line 21
def queue
  @queue ||= channel.queue(queue_name, auto_delete: false)
end
return_queue() click to toggle source
# File lib/burrow/connection.rb, line 29
def return_queue
  @return_queue ||= channel.queue('', exclusive: true)
end