class Protobuf::Rpc::Connectors::EMClient

def send_data
  request_buffer = ::Protobuf::Rpc::Buffer.new(:write)
  request_buffer.set_data(@request_data)
  log_debug { "[#{log_signature}] sending data: #{request_buffer.inspect}" }
  super(request_buffer.write)
rescue
  fail(:RPC_ERROR, 'Connection error: %s' % $!.message)
end