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