Module: Liebre::Adapter::Interface::Chan
- Included in:
- Bunny::Chan
- Defined in:
- lib/liebre/adapter/interface/chan.rb
Instance Method Summary collapse
- #close ⇒ Object
- #default_exchange ⇒ Object
- #exchange(name, type, opts) ⇒ Object
- #queue(name, opts) ⇒ Object
- #set_prefetch(count) ⇒ Object
Instance Method Details
#close ⇒ Object
22 23 24 |
# 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 ⇒ Object
6 7 8 |
# 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) ⇒ Object
10 11 12 |
# 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) ⇒ Object
14 15 16 |
# 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) ⇒ Object
18 19 20 |
# 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 |