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/10/16 23:51:08 UTC
[2/2] usergrid git commit: change queue impl
change queue impl
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/e5e9d021
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/e5e9d021
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/e5e9d021
Branch: refs/heads/remove-inmemory-event-service
Commit: e5e9d021ba1b27688fe6cf88482473980c0c3141
Parents: 6a3bae1
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Oct 16 15:50:48 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Oct 16 15:50:48 2015 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/persistence/queue/DefaultQueueManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/e5e9d021/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
index 3b6fe07..08f17a0 100644
--- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
+++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/DefaultQueueManager.java
@@ -36,7 +36,7 @@ import java.util.concurrent.TimeUnit;
* Default queue manager implementation, uses in memory linked queue
*/
public class DefaultQueueManager implements QueueManager {
- public ArrayBlockingQueue<QueueMessage> queue = new ArrayBlockingQueue<>(1000);
+ public ArrayBlockingQueue<QueueMessage> queue = new ArrayBlockingQueue<>(10000);
@Override
public Observable<QueueMessage> getMessages(int limit, int transactionTimeout, int waitTime, Class klass) {