Method: Qpid#initialize

Defined in:
lib/qpid.rb

#initialize(params = {}) ⇒ Qpid

Returns a new instance of Qpid.



49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/qpid.rb', line 49

def initialize(params = {})
  missing_params = []
  @user = params[:user] || params['user'] || missing_params << 'user' 
  @host = params[:host] || params['host'] || missing_params << 'host'
  @path = params[:path] || params['path'] || missing_params << 'path'
  if missing_params.length > 0
    raise ArgumentError, "Did not specify #{missing_params.join(', ')} to initialize QPID object"
  end
  @port = params[:port] || DEF_PORT
  @timeout_interval = params[:timeout_interval] || params['timeout_interval'] || DEF_TIMEOUT_INTERVAL
  @query_interval = params[:query_interval] || params['query_interval'] || DEF_QUERY_INTERVAL
  @error_tolerance = params[:error_tolerance] || params['error_tolerance'] || DEF_ERROR_TOLERANCE
  @client = params[:client] || params['client'] || HTTPClient.new
  if (params[:http_user] && params[:http_password])
    client.set_auth(nil, params[:http_user], params[:http_password])
  elsif (params['http_user'] && params['http_password'])
    client.set_auth(nil, params['http_user'], params['http_password'])
  end
end