class Protobuf::Rpc::Connectors::EMClient

def initialize(options = {}, &failure_cb)
  @failure_cb = failure_cb
  @options = DEFAULT_OPTIONS.merge(options)
  @response_buffer = ::Protobuf::Rpc::Buffer.new(:read)
  verify_options!
  log_debug { sign_message("Client Initialized: #{options.inspect}") }
rescue => e
  fail(:RPC_ERROR, "Failed to initialize connection: #{e.message}")
end