Class: Liebre::Actor::RPC::Client::Resources

Inherits:
Object
  • Object
show all
Defined in:
lib/liebre/actor/rpc/client/resources.rb

Constant Summary collapse

DEFAULT_PREFIX = 
"rpc_responses"
QUEUE_OPTS = 
{:auto_delete => true,
:exclusive   => true,
:durable     => false}

Instance Method Summary collapse

Constructor Details

#initialize(context) ⇒ Resources

Returns a new instance of Resources.



15
16
17
 
# File 'lib/liebre/actor/rpc/client/resources.rb', line 15

def initialize context
  @context = context
end

Instance Method Details

#request_exchange ⇒ Object 



23
24
25
 
# File 'lib/liebre/actor/rpc/client/resources.rb', line 23

def request_exchange
  @request_exchange ||= declare.exchange(exchange_config)
end

#response_queue ⇒ Object 



19
20
21
 
# File 'lib/liebre/actor/rpc/client/resources.rb', line 19

def response_queue
  @response_queue ||= declare.queue(:name => queue_name, :opts => QUEUE_OPTS)
end