class Liebre::Actor::RPC::Server::Resources

Attributes

context[R]

Public Class Methods

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

Public Instance Methods

request_exchange() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 21
def request_exchange
  @request_exchange ||= declare.exchange(exchange_config)
end
request_queue() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 15
def request_queue
  @request_queue ||= declare.queue(queue_config).tap do |queue|
    declare.bind(queue, request_exchange, bind_config)
  end
end
response_exchange() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 11
def response_exchange
  @response_exchange ||= declare.default_exchange
end

Private Instance Methods

bind_config() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 35
def bind_config
  spec.fetch(:bind, {})
end
declare() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 43
def declare
  context.declare
end
exchange_config() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 31
def exchange_config
  spec.fetch(:exchange)
end
queue_config() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 27
def queue_config
  spec.fetch(:queue)
end
spec() click to toggle source
# File lib/liebre/actor/rpc/server/resources.rb, line 39
def spec
  context.spec
end