class Protobuf::Rpc::Connectors::EMClient

def send_data
  request_buffer = ::Protobuf::Rpc::Buffer.new(:write)
  request_buffer.set_data(@request_data)
  log_debug { sign_message("sending data: #{request_buffer.inspect}") }
  super(request_buffer.write)
rescue => e
  fail(:RPC_ERROR, "Connection error: #{e.message}")
end