usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mru...@apache.org
Subject usergrid git commit: Remove not needed parallelstream and set the default back pressure for indexing quorum reads to be 5 seconds.
Date Wed, 09 Mar 2016 22:15:14 GMT
Repository: usergrid
Updated Branches:
  refs/heads/release-2.1.1 b06190a35 -> 36a01617c


Remove not needed parallelstream and set the default back pressure for indexing quorum reads
to be 5 seconds.


Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/36a01617
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/36a01617
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/36a01617

Branch: refs/heads/release-2.1.1
Commit: 36a01617cb88ff1d9c2c1499089b7a2d13cd6eb1
Parents: b06190a
Author: Michael Russo <mrusso@apigee.com>
Authored: Wed Mar 9 14:14:16 2016 -0800
Committer: Michael Russo <mrusso@apigee.com>
Committed: Wed Mar 9 14:14:16 2016 -0800

----------------------------------------------------------------------
 .../corepersistence/asyncevents/AsyncEventServiceImpl.java         | 2 +-
 .../main/java/org/apache/usergrid/persistence/queue/QueueFig.java  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/usergrid/blob/36a01617/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
index 3f623d8..200d1e6 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
@@ -285,7 +285,7 @@ public class AsyncEventServiceImpl implements AsyncEventService {
             logger.debug("callEventHandlers with {} message", messages.size());
         }
 
-        Stream<IndexEventResult> indexEventResults = messages.parallelStream().map(message
->
+        Stream<IndexEventResult> indexEventResults = messages.stream().map(message
->
 
         {
             AsyncEvent event = null;

http://git-wip-us.apache.org/repos/asf/usergrid/blob/36a01617/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java
b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java
index 383ab80..a7d299e 100644
--- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java
+++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/QueueFig.java
@@ -84,7 +84,7 @@ public interface QueueFig extends GuicyFig {
     int getVisibilityTimeout();
 
     @Key( "usergrid.queue.localquorum.timeout")
-    @Default("3000") // 3 seconds
+    @Default("5000") // 5 seconds
     int getLocalQuorumTimeout();
 
     @Key( "usergrid.queue.client.connection.timeout")


Mime
View raw message