You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2015/08/12 23:18:06 UTC
incubator-usergrid git commit: Fixes-rethrow
Repository: incubator-usergrid
Updated Branches:
refs/heads/subscription-bugfixes 9b829ef4a -> d7310c503
Fixes-rethrow
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/d7310c50
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/d7310c50
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/d7310c50
Branch: refs/heads/subscription-bugfixes
Commit: d7310c5037af3824c38fda03b78e7146b6e9f057
Parents: 9b829ef
Author: Todd Nine <tn...@apigee.com>
Authored: Wed Aug 12 15:18:03 2015 -0600
Committer: Todd Nine <tn...@apigee.com>
Committed: Wed Aug 12 15:18:03 2015 -0600
----------------------------------------------------------------------
.../usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/d7310c50/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
index ed70c62..2c7122b 100644
--- a/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
+++ b/stack/corepersistence/queryindex/src/main/java/org/apache/usergrid/persistence/index/impl/EsIndexBufferConsumerImpl.java
@@ -272,7 +272,9 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
try {
subscriber.onNext( indexOp );
}catch(Exception e){
+ //re-throws so the caller can determine failover
log.error( "Unable to process message for indexOp {}, error follows.", indexOp, e );
+ throw e;
}
}