Class: Liebre::Actor::Consumer::Resources

Inherits:
Object
  • Object
show all
Defined in:
lib/liebre/actor/consumer/resources.rb,
lib/liebre/actor/consumer/resources/config.rb

Defined Under Namespace

Classes: Config

Instance Method Summary collapse

Constructor Details

#initialize(context) ⇒ Resources

Returns a new instance of Resources.



8
9
10
 
# File 'lib/liebre/actor/consumer/resources.rb', line 8

def initialize context
  @context = context
end

Instance Method Details

#dead_exchange ⇒ Object 



28
29
30
 
# File 'lib/liebre/actor/consumer/resources.rb', line 28

def dead_exchange
  @dead_exchange ||= declare.exchange(config.dead_exchange)
end

#dead_queue ⇒ Object 



22
23
24
25
26
 
# File 'lib/liebre/actor/consumer/resources.rb', line 22

def dead_queue
  @dead_queue ||= declare.queue(config.dead_queue).tap do |queue|
    declare.bind(queue, dead_exchange)
  end
end

#exchange ⇒ Object 



18
19
20
 
# File 'lib/liebre/actor/consumer/resources.rb', line 18

def exchange
  @exchange ||= declare.exchange(config.exchange)
end

#queue ⇒ Object 



12
13
14
15
16
 
# File 'lib/liebre/actor/consumer/resources.rb', line 12

def queue
  @queue ||= declare.queue(config.queue).tap do |queue|
    declare.bind(queue, exchange, config.bind)
  end
end