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