module Liebre::Adapter::Interface::Queue

Public Instance Methods

ack(info, opts = {}) click to toggle source
# File lib/liebre/adapter/interface/queue.rb, line 22
def ack info, opts = {}
  raise NotImplementedError, "All adapters must implement queue ack(info, opts) to ack messages"
end
bind(exchange, opts = {}) click to toggle source
# File lib/liebre/adapter/interface/queue.rb, line 10
def bind exchange, opts = {}
  raise NotImplementedError, "All adapters must implement queue bind(exchange, opts) to bind the queue to an exchange"
end
get(opts = {}) click to toggle source
# File lib/liebre/adapter/interface/queue.rb, line 14
def get opts = {}, &block
  raise NotImplementedError, "All adapters must implement queue get(opts, &block) to get messages"
end
nack(info, opts = {}) click to toggle source
# File lib/liebre/adapter/interface/queue.rb, line 26
def nack info, opts = {}
  raise NotImplementedError, "All adapters must implement queue nack(info, opts) to nack messages"
end
name() click to toggle source
# File lib/liebre/adapter/interface/queue.rb, line 6
def name
  raise NotImplementedError, "All adapters must implement queue name() to get the name of the queue"
end
reject(info, opts = {}) click to toggle source
# File lib/liebre/adapter/interface/queue.rb, line 30
def reject info, opts = {}
  raise NotImplementedError, "All adapters must implement queue reject(info, opts) to reject messages"
end
subscribe(opts = {}) click to toggle source
# File lib/liebre/adapter/interface/queue.rb, line 18
def subscribe opts = {}, &block
  raise NotImplementedError, "All adapters must implement queue subscribe(opts, block) consume messajes constantly"
end