Added more logging statements
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/d35fea56 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/d35fea56 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/d35fea56 Branch: refs/heads/master Commit: d35fea5636acfd384f0b35069cdc59e515ec0372 Parents: 8b4faf7 Author: Todd Nine <[email protected]> Authored: Fri Oct 23 10:04:21 2015 -0600 Committer: Todd Nine <[email protected]> Committed: Fri Oct 23 10:04:21 2015 -0600 ---------------------------------------------------------------------- .../corepersistence/results/ObservableQueryExecutor.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/d35fea56/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java index 7b31d19..7a32dce 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/results/ObservableQueryExecutor.java @@ -23,6 +23,9 @@ package org.apache.usergrid.corepersistence.results; import java.util.Iterator; import java.util.NoSuchElementException; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + import org.apache.usergrid.corepersistence.pipeline.read.ResultsPage; import org.apache.usergrid.persistence.Results; @@ -39,6 +42,7 @@ import rx.Observable; public abstract class ObservableQueryExecutor<T> implements QueryExecutor { + private static final Logger logger = LoggerFactory.getLogger( ObservableQueryExecutor.class ); private Results results; private Optional<String> cursor; @@ -131,9 +135,12 @@ public abstract class ObservableQueryExecutor<T> implements QueryExecutor { observable = buildNewResultsPage( cursor ).map( resultsPage -> createResultsInternal( resultsPage ) ).defaultIfEmpty( new Results() ); + logger.trace( "Trying to load results page" ); //take the first from our observable final Results resultsPage = observable.take(1).toBlocking().first(); + logger.trace( "Results page loaded {}", resultsPage ); + //set the results for the iterator this.results = resultsPage;
