module Liebre::Adapter::Interface::Chan

Public Instance Methods

close() click to toggle source
# File lib/liebre/adapter/interface/chan.rb, line 22
def close
  raise NotImplementedError, "All adapters must implement channel close() to close a channel"
end
default_exchange() click to toggle source
# File lib/liebre/adapter/interface/chan.rb, line 6
def default_exchange
  raise NotImplementedError, "All adapters must implement channel default_exchange() to build the default exchange"
end
exchange(name, type, opts) click to toggle source
# File lib/liebre/adapter/interface/chan.rb, line 10
def exchange name, type, opts
  raise NotImplementedError, "All adapters must implement channel exchange(name, type, opts) to declare and build exchanges"
end
queue(name, opts) click to toggle source
# File lib/liebre/adapter/interface/chan.rb, line 14
def queue name, opts
  raise NotImplementedError, "All adapters must implement channel queue(name, opts) to declare and build queues"
end
set_prefetch(count) click to toggle source
# File lib/liebre/adapter/interface/chan.rb, line 18
def set_prefetch count
  raise NotImplementedError, "All adapters must implement channel set_prefetch(count) to set the prefetch count for this channel"
end