}
public List poll(MyBatisConsumer consumer, MyBatisEndpoint endpoint) throws Exception {
SqlSession session = endpoint.getSqlSessionFactory().openSession();
try {
return session.selectList(endpoint.getStatement(), null);
} finally {
session.close();
}
}
}