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