usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toddn...@apache.org
Subject [19/50] [abbrv] incubator-usergrid git commit: Added parameters for SQS listen operations, changed defaults since values were getting /1000 for milliseconds
Date Thu, 28 May 2015 12:53:24 GMT
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/USERGRID-669
Commit: e27d9f0350fade629ddf5a303bc111cf3a25a773
Parents: 0791916
Author: Jeff West <jwest@apigee.com>
Authored: Tue May 26 09:04:21 2015 -0700
Committer: Jeff West <jwest@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();


Mime
View raw message