usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject [3/3] incubator-usergrid git commit: Fixes-rethrow
Date Wed, 12 Aug 2015 21:22:01 GMT
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/two-dot-o-dev
Commit: d7310c5037af3824c38fda03b78e7146b6e9f057
Parents: 9b829ef
Author: Todd Nine <tnine@apigee.com>
Authored: Wed Aug 12 15:18:03 2015 -0600
Committer: Todd Nine <tnine@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;
             }
         }
 


Mime
View raw message