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