OrclToMngSyncReader.java 文件源码

private FindIterable<O2MSyncEventLog> getCursor() throws InterruptedException {
    Thread.sleep(waitTime);
    waitTime *= retryCount;
    logCollection = MongoConnection.INSTANCE.getMongoDataBase()
            .getCollection(String.valueOf(ApplicationCollections.O2MSyncEventLog), O2MSyncEventLog.class);
    FindIterable<O2MSyncEventLog> it = logCollection
            .find(Filters.and(Filters.eq(O2MSyncEventLogCodec.EVENT_ID, String.valueOf(eventId)),
                    Filters.eq(O2MSyncEventLogCodec.STATUS, O2MSyncEventLogCodec.PENDING)))
            .cursorType(CursorType.TailableAwait).noCursorTimeout(true);
    return it;
}