class Liebre::Adapter::Bunny::Queue
Attributes
queue[R]
Public Class Methods
new(queue)
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 9 def initialize queue @queue = queue end
Public Instance Methods
ack(info, opts = {})
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 23 def ack info, opts = {} multiple = opts.fetch(:multiple, false) channel.ack(info.delivery_tag, multiple) end
bind(exchange, opts = {})
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 17 def bind exchange, opts = {} bunny_exchange = exchange.exchange queue.bind(bunny_exchange, opts) end
get(opts = {})
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 42 def get opts = {}, &block queue.get(opts, &block) end
nack(info, opts = {})
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 29 def nack info, opts = {} multiple = opts.fetch(:multiple, false) requeue = opts.fetch(:requeue, false) channel.nack(info.delivery_tag, multiple, requeue) end
name()
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 13 def name queue.name end
reject(info, opts = {})
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 36 def reject info, opts = {} requeue = opts.fetch(:requeue, false) channel.reject(info.delivery_tag, requeue) end
subscribe(opts = {})
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 46 def subscribe opts = {}, &block queue.subscribe(opts, &block) end
Private Instance Methods
channel()
click to toggle source
# File lib/liebre/adapter/bunny/queue.rb, line 52 def channel queue.channel end