slumberdb/slumberdb-service-model/src/main/java/org/boon/slumberdb/stores/mysql/MySQLDataStore.java
protected void flushWritesIfNeeded() throws InterruptedException {

        long now = timer.time();

        /* Every 30 seconds  flush the write queue. */
        if (now - lastWriteFlushTime > dataStoreConfig.dbWriteFlushQueueIntervalMS()) {

            if (outputMap.size() > 0) {

                if (!writeQueue.offer(new LinkedHashMap(outputMap))) {
                    logger.warn("MySQL STORE QUEUE IS FULL", writeQueue.size());

                } else {
                    outputMap.clear();
                }

                lastWriteFlushTime = now;
            }


            if (removeList.size() > 0) {


                if (!writeQueue.offer(new ArrayList<>(removeList))) {
                    logger.warn("MySQL LOAD QUEUE IS FULL", writeQueue.size());
                } else {
                    removeList.clear();
                }


            }


        }
    }
protected void flushWritesIfNeeded() throws InterruptedException {

        long now = timer.time();

        /* Every 30 seconds  flush the write queue. */
        if (now - lastWriteFlushTime > dataStoreConfig.dbWriteFlushQueueIntervalMS()) {

            if (outputMap.size() > 0) {

                if (!writeQueue.offer(new LinkedHashMap(outputMap))) {
                    logger.warn("MySQL STORE QUEUE IS FULL", writeQueue.size());

                } else {
                    outputMap.clear();
                }

                lastWriteFlushTime = now;
            }


            if (removeList.size() > 0) {


                if (!writeQueue.offer(new ArrayList<>(removeList))) {
                    logger.warn("MySQL LOAD QUEUE IS FULL", writeQueue.size());
                } else {
                    removeList.clear();
                }


            }


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