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