Class: RosettaQueue::Gateway::EventedExchange::BaseExchange

Inherits:

Object

• Object
• RosettaQueue::Gateway::EventedExchange::BaseExchange

Defined in:

lib/rosetta_queue/adapters/amqp_evented.rb

Direct Known Subclasses

DirectExchange, FanoutExchange

Instance Method Summary

• #delete(destination) ⇒ Object
• #initialize(adapter_settings, options = {}) ⇒ BaseExchange constructor

  A new instance of BaseExchange.

Constructor Details

#initialize(adapter_settings, options = {}) ⇒ BaseExchange

Returns a new instance of BaseExchange.

# File 'lib/rosetta_queue/adapters/amqp_evented.rb', line 29

def initialize(adapter_settings, options={})
  @adapter_settings, @options = adapter_settings, options
end

Instance Method Details

#delete(destination) ⇒ Object

# File 'lib/rosetta_queue/adapters/amqp_evented.rb', line 33

def delete(destination)
  conn.queue(destination).delete(@options)
end