You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/03/11 05:47:34 UTC
[2/4] usergrid git commit: Remove not needed parallelstream and set
the default back pressure for indexing quorum reads to be 5 seconds.
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/master
Commit: 36a01617cb88ff1d9c2c1499089b7a2d13cd6eb1
Parents: b06190a
Author: Michael Russo <mr...@apigee.com>
Authored: Wed Mar 9 14:14:16 2016 -0800
Committer: Michael Russo <mr...@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")