protected List<JobPo> load(String loadTaskTrackerNodeGroup, int loadSize) {
        // load
        String tableName = JobQueueUtils.getExecutableQueueName(loadTaskTrackerNodeGroup);
        Query<JobPo> query = template.createQuery(tableName, JobPo.class);
        query.field("isRunning").equal(false)
                .filter("triggerTime < ", SystemClock.now())
                .order(" priority, triggerTime , gmtCreated").offset(0).limit(loadSize);
        return query.asList();
    }
@author Robert HG (254963746@qq.com) on 8/13/15.
lts-core/src/main/java/com/github/ltsopensource/queue/mongo/MongoPreLoader.java