core/src/main/java/com/digitalpebble/stormcrawler/persistence/AbstractQueryingSpout.java
private boolean triggerQueries() {
        if (timeLastQueryReceived != 0 && maxDelayBetweenQueries > 0) {
            // check that we allowed some time between queries
            long difference = System.currentTimeMillis()
                    - timeLastQueryReceived;
            if (difference > maxDelayBetweenQueries) {
                return true;
            }
        }
        return false;
    }
private boolean triggerQueries() {
        if (timeLastQueryReceived != 0 && maxDelayBetweenQueries > 0) {
            // check that we allowed some time between queries
            long difference = System.currentTimeMillis()
                    - timeLastQueryReceived;
            if (difference > maxDelayBetweenQueries) {
                return true;
            }
        }
        return false;
    }
private boolean triggerQueries ( ) { if ( timeLastQueryReceived != 0 && maxDelayBetweenQueries > 0 ) { // check that we allowed some time between queries long difference = System . currentTimeMillis ( ) - timeLastQueryReceived ; if ( difference > maxDelayBetweenQueries ) { return true ; } } return false ; }
Indicates whether enough time has elapsed since receiving the results of
the previous query so that a new one can be sent even if the buffer is
not empty. Applies to asynchronous clients only.
Indicates whether enough time has elapsed since receiving the results of the previous query so that a new one can be sent even if the buffer is not empty . Applies to asynchronous clients only .