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