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; } }
