Module: Liebre::Adapter::Interface::Chan

Included in:
Bunny::Chan
Defined in:
lib/liebre/adapter/interface/chan.rb

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object

Raises:

  • (NotImplementedError) 


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

Raises:

  • (NotImplementedError) 


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

Raises:

  • (NotImplementedError) 


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

Raises:

  • (NotImplementedError) 


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

Raises:

  • (NotImplementedError) 


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