You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/06/15 16:25:39 UTC
[46/50] [abbrv] usergrid git commit: Fix logging statement.
Fix logging statement.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/8814a144
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/8814a144
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/8814a144
Branch: refs/heads/master
Commit: 8814a144b66054048be96a1c892fd750ee327327
Parents: 4bf7761
Author: Michael Russo <mr...@apigee.com>
Authored: Tue Jun 14 21:59:24 2016 -0700
Committer: Michael Russo <mr...@apigee.com>
Committed: Tue Jun 14 21:59:24 2016 -0700
----------------------------------------------------------------------
.../corepersistence/asyncevents/AsyncEventServiceImpl.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/8814a144/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
index 8d050fe..0bff887 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
@@ -355,9 +355,12 @@ public class AsyncEventServiceImpl implements AsyncEventService {
throw new Exception("Unknown EventType for message: "+ message.getStringBody().trim());
}
- if( single.isEmpty() ){
- logger.warn("No index operation messages came back from event processing for msg {} ",
- message.getStringBody().trim());
+
+ if( !(event instanceof ElasticsearchIndexEvent)
+ && !(event instanceof InitializeApplicationIndexEvent)
+ && single.isEmpty() ){
+ logger.warn("No index operation messages came back from event processing for msg: {} ",
+ message.getStringBody().trim());
}