Class: BasicJRPC::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/basicjrpc/client.rb

Overview

Responding Client

Direct Known Subclasses

FAFClient

Instance Method Summary collapse

Constructor Details

#initialize(queue, timeout = 5) ⇒ Client

Returns a new instance of Client.



5
6
7
8
9
10
 
# File 'lib/basicjrpc/client.rb', line 5

def initialize(queue, timeout = 5)
  @nsq_producer = Nsq::Producer.new(nsqd: 'dockerlb:4150', topic: queue)
  @queue = queue
  @payload = {}
  @timeout = timeout
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(m, *args, &block) ⇒ Object 



12
13
14
 
# File 'lib/basicjrpc/client.rb', line 12

def method_missing(m, *args, &block)
  send_request({ :method_name => m, :method_arguments => args })
end

Instance Method Details

#send_request(payload) ⇒ Object 



16
17
18
19
20
21
22
23
 
# File 'lib/basicjrpc/client.rb', line 16

def send_request payload
  payload[:message_id] = SecureRandom.uuid
  payload[:response] = true
  
  @nsq_producer.write(Oj.dump(payload))

  return Oj.load(Nsq::Consumer.new(nsqlookupd: 'dockerlb:4161',topic: payload[:message_id], channel: 'client').pop)
end