class Newque::Client
Attributes
protocol[R]
Public Class Methods
new(protocol, host, port, protocol_options:nil, timeout:10000)
click to toggle source
# File lib/newque/clients/client.rb, line 10 def initialize protocol, host, port, protocol_options:nil, timeout:10000 @protocol = protocol @instance = if protocol == :zmq Newque_zmq.new host, port, (protocol_options || {}), timeout elsif protocol == :http Newque_http.new host, port, (protocol_options || {}), timeout else raise NewqueError.new "Invalid protocol [#{protocol}]. Must be either :zmq or :http" end end