slumberdb/slumberdb-service-model/src/main/java/org/boon/slumberdb/stores/mysql/MySQLDataStore.java
protected void flushReadsIfNeeded() throws InterruptedException {
        long now = timer.time();

        /* Every 250 ms flush the read queue. */
        if (now - lastReadFlushTime > flushQueueInterval && readList.size() > 0) {


            if (!loadQueue.offer(new ArrayList<>(readList))) {
                logger.warn("MySQL LOAD QUEUE IS FULL", loadQueue.size());
            } else {
                readList.clear();
            }
            lastReadFlushTime = now;


        }
    }
protected void flushReadsIfNeeded() throws InterruptedException {
        long now = timer.time();

        /* Every 250 ms flush the read queue. */
        if (now - lastReadFlushTime > flushQueueInterval && readList.size() > 0) {


            if (!loadQueue.offer(new ArrayList<>(readList))) {
                logger.warn("MySQL LOAD QUEUE IS FULL", loadQueue.size());
            } else {
                readList.clear();
            }
            lastReadFlushTime = now;


        }
    }
Will flush to secondary storage if needed. This is used mostly by REMOTE_DB at the moment.