class Liebre::Actor::Consumer::Resources

Attributes

context[R]

Public Class Methods

new(context) click to toggle source
# File lib/liebre/actor/consumer/resources.rb, line 8
def initialize context
  @context = context
end

Public Instance Methods

dead_exchange() click to toggle source
# File lib/liebre/actor/consumer/resources.rb, line 28
def dead_exchange
  @dead_exchange ||= declare.exchange(config.dead_exchange)
end
dead_queue() click to toggle source
# 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() click to toggle source
# File lib/liebre/actor/consumer/resources.rb, line 18
def exchange
  @exchange ||= declare.exchange(config.exchange)
end
queue() click to toggle source
# 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

Private Instance Methods

config() click to toggle source
# File lib/liebre/actor/consumer/resources.rb, line 38
def config
  @config ||= Config.new(context.spec)
end
declare() click to toggle source
# File lib/liebre/actor/consumer/resources.rb, line 34
def declare
  context.declare
end