class Multiwoven::Integrations::Core::SourceConnector
def query(connection, query)
This needs to be implemented as private method
def query(connection, query) # return list of RecordMessage end
def query(connection, query) # return list of RecordMessage end