You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2015/03/30 21:58:44 UTC
[40/50] incubator-usergrid git commit: TODO for proper error handling
once onErrorResumeNext() is implemented.
TODO for proper error handling once onErrorResumeNext() is implemented.
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/c0384d51
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/c0384d51
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/c0384d51
Branch: refs/heads/two-dot-o-dev
Commit: c0384d51e1842ed39649f54b4c5829aba27c9b50
Parents: 0c25d85
Author: Dave Johnson <dm...@apigee.com>
Authored: Fri Mar 20 18:40:47 2015 -0400
Committer: Dave Johnson <dm...@apigee.com>
Committed: Fri Mar 20 18:40:47 2015 -0400
----------------------------------------------------------------------
.../persistence/index/impl/EsIndexBufferConsumerImpl.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/c0384d51/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 b0d6047..ecee76b 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
@@ -329,6 +329,8 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
failureMonitor.success();
+ boolean error = false;
+
for (BulkItemResponse response : responses) {
if (response.isFailed()) {
@@ -339,7 +341,14 @@ public class EsIndexBufferConsumerImpl implements IndexBufferConsumer {
response.getIndex(),
response.getFailureMessage()
);
+
+ error = true;
}
}
+
+ if ( error ) {
+ // TODO: throw error once onErrorResumeNext() implemented in startWorker()
+ //throw new RuntimeException("Error during processing of bulk index operations")
+ }
}
}