class Multiwoven::Integrations::Source::VertexModel::Client

def process_response(response)
  data = JSON.parse(response.data)
  [RecordMessage.new(data: data, emitted_at: Time.now.to_i).to_multiwoven_message]
end