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();
                }


            }


        }
    }
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.
Will flush to secondary storage if needed . This is used mostly by REMOTE_DB at the moment .