Reduces logging and adds filter into delete listener
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/b7a22c2d Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/b7a22c2d Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/b7a22c2d Branch: refs/heads/USERGRID-933 Commit: b7a22c2d51602e32692b22ad584ce128b1592ed0 Parents: 6233bf0 Author: Todd Nine <tn...@apigee.com> Authored: Tue Sep 15 17:27:14 2015 -0600 Committer: Todd Nine <tn...@apigee.com> Committed: Tue Sep 15 17:27:14 2015 -0600 ---------------------------------------------------------------------- stack/core/src/test/resources/log4j.properties | 4 ++-- .../persistence/graph/impl/stage/EdgeDeleteRepairImpl.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/b7a22c2d/stack/core/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/stack/core/src/test/resources/log4j.properties b/stack/core/src/test/resources/log4j.properties index 93951fe..4267293 100644 --- a/stack/core/src/test/resources/log4j.properties +++ b/stack/core/src/test/resources/log4j.properties @@ -19,7 +19,7 @@ # output messages into a rolling log file as well as stdout #log4j.rootLogger=ERROR,stdout\ -log4j.rootLogger=DEBUG,stdout +log4j.rootLogger=INFO,stdout # stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender @@ -48,7 +48,7 @@ log4j.logger.org.apache.usergrid.corepersistence.migration=WARN #Debug our queries #log4j.logger.org.apache.usergrid.persistence.index.impl.EsApplicationEntityIndexImpl=DEBUG -log4j.logger.org.apache.usergrid.corepersistence.service.ConnectionServiceImpl=DEBUG +#log4j.logger.org.apache.usergrid.corepersistence.service.ConnectionServiceImpl=DEBUG #log4j.logger.org.apache.usergrid.persistence.index.impl=DEBUG #log4j.logger.org.apache.usergrid.corepersistence.CpSetup=INFO http://git-wip-us.apache.org/repos/asf/usergrid/blob/b7a22c2d/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/stage/EdgeDeleteRepairImpl.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/stage/EdgeDeleteRepairImpl.java b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/stage/EdgeDeleteRepairImpl.java index 643dcc1..a87a079 100644 --- a/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/stage/EdgeDeleteRepairImpl.java +++ b/stack/corepersistence/graph/src/main/java/org/apache/usergrid/persistence/graph/impl/stage/EdgeDeleteRepairImpl.java @@ -79,7 +79,7 @@ public class EdgeDeleteRepairImpl implements EdgeDeleteRepair { //merge source and target then deal with the distinct values - return Observable.just( edge ) + return Observable.just( edge ).filter( markedEdge-> markedEdge.isDeleted() ) .doOnNext( markedEdge -> { //it's still in the same state as it was when we queued it. Remove it LOG.info( "Removing edge {} ", markedEdge );
