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 { "[#{log_signature}] Client Initialized: %s" % options.inspect }
rescue
  fail(:RPC_ERROR, 'Failed to initialize connection: %s' % $!.message)
end