Class: Combi::InProcess
Constant Summary
Constants inherited from Bus
Instance Attribute Summary
Attributes inherited from Bus
Instance Method Summary collapse
Methods inherited from Bus
#add_service, #enable, #initialize, #post_initialize, #restart!, #start!, #stop!
Constructor Details
This class inherits a constructor from Combi::Bus
Instance Method Details
#request(service_name, kind, message, options = {}) ⇒ Object
6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 |
# File 'lib/combi/buses/in_process.rb', line 6 def request(service_name, kind, , = {}) [:timeout] ||= RPC_DEFAULT_TIMEOUT = Yajl::Parser.parse(Yajl::Encoder.encode(), symbolize_keys: true) if [:fast] operation = Proc.new do Timeout.timeout([:timeout]) do invoke_service(service_name, kind, ) end end EM::defer operation return nil else waiter = EventMachine::DefaultDeferrable.new begin Timeout.timeout([:timeout]) do response = invoke_service(service_name, kind, ) response.callback do |service_response| waiter.succeed service_response end response.errback do |service_response| waiter.fail error: service_response end end rescue Timeout::Error => e waiter.fail error: 'Timeout::Error' end waiter end end |