You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2015/05/28 01:52:40 UTC
[04/15] incubator-usergrid git commit: Added parameters for SQS
listen operations,
changed defaults since values were getting /1000 for milliseconds
Added parameters for SQS listen operations, changed defaults since values were getting /1000 for milliseconds
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/e27d9f03
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/e27d9f03
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/e27d9f03
Branch: refs/heads/two-dot-o-dev
Commit: e27d9f0350fade629ddf5a303bc111cf3a25a773
Parents: 0791916
Author: Jeff West <jw...@apigee.com>
Authored: Tue May 26 09:04:21 2015 -0700
Committer: Jeff West <jw...@apigee.com>
Committed: Tue May 26 09:04:21 2015 -0700
----------------------------------------------------------------------
.../corepersistence/index/IndexProcessorFig.java | 13 ++++++++++---
1 file changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/e27d9f03/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexProcessorFig.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexProcessorFig.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexProcessorFig.java
index e4b2329..3feaeaf 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexProcessorFig.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/index/IndexProcessorFig.java
@@ -58,6 +58,10 @@ public interface IndexProcessorFig extends GuicyFig {
*/
String INDEX_QUEUE_READ_TIMEOUT = "elasticsearch.queue_read_timeout";
+ /**
+ * Amount of time to wait when reading from the queue
+ */
+ String INDEX_QUEUE_VISIBILITY_TIMEOUT = "elasticsearch.queue_visibility_timeout";
@Default( "1000" )
@@ -65,10 +69,15 @@ public interface IndexProcessorFig extends GuicyFig {
long getFailureRetryTime();
//give us 60 seconds to process the message
- @Default( "60" )
+ @Default( "100000" )
@Key( INDEX_QUEUE_READ_TIMEOUT )
int getIndexQueueTimeout();
+ //give us 60 seconds to process the message
+ @Default( "12000000" )
+ @Key( INDEX_QUEUE_VISIBILITY_TIMEOUT )
+ int getIndexQueueVisibilityTimeout();
+
@Default( "1" )
@Key( ELASTICSEARCH_WORKER_COUNT )
int getWorkerCount();
@@ -77,12 +86,10 @@ public interface IndexProcessorFig extends GuicyFig {
@Key( ELASTICSEARCH_QUEUE_IMPL )
String getQueueImplementation();
-
@Default("1000")
@Key("elasticsearch.reindex.flush.interval")
int getUpdateInterval();
-
@Default("false")
@Key("elasticsearch.queue_impl.resolution")
boolean resolveSynchronously();