def initialize(login = '', passcode = '', host = 'localhost', port = 61613, reliable = false, reconnect_delay = 5, connect_headers = {})
@received_messages = []
if login.is_a?(Hash)
hashed_initialize(login)
else
@host = host
@port = port
@login = login
@passcode = passcode
@reliable = reliable
@reconnect_delay = reconnect_delay
@connect_headers = connect_headers
@ssl = false
@parameters = nil
@parse_timeout = 5
end
@transmit_semaphore = Mutex.new
@read_semaphore = Mutex.new
@socket_semaphore = Mutex.new
@subscriptions = {}
@failure = nil
@connection_attempts = 0
socket
end