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/usergrid-1268-akka-211 Commit: 8814a144b66054048be96a1c892fd750ee327327 Parents: 4bf7761 Author: Michael Russo <[email protected]> Authored: Tue Jun 14 21:59:24 2016 -0700 Committer: Michael Russo <[email protected]> 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()); }
