Index: oak-core/src/main/java/org/apache/jackrabbit/oak/spi/commit/BackgroundObserver.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- oak-core/src/main/java/org/apache/jackrabbit/oak/spi/commit/BackgroundObserver.java	(date 1479998211000)
+++ oak-core/src/main/java/org/apache/jackrabbit/oak/spi/commit/BackgroundObserver.java	(revision )
@@ -55,6 +55,8 @@
  */
 public class BackgroundObserver implements Observer, Closeable {
 
+    public final static int DEFAULT_QUEUE_SIZE = 10000;
+
     /**
      * Signal for the background thread to stop processing changes.
      */
@@ -179,7 +181,7 @@
     public BackgroundObserver(
             @Nonnull Observer observer,
             @Nonnull Executor executor) {
-        this(observer, executor, 1000);
+        this(observer, executor, DEFAULT_QUEUE_SIZE);
     }
 
     /**
Index: oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/Jcr.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/Jcr.java	(date 1479998211000)
+++ oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/Jcr.java	(revision )
@@ -77,7 +77,7 @@
  * {@link Jcr#createRepository()}.</p>
  */
 public class Jcr {
-    public static final int DEFAULT_OBSERVATION_QUEUE_LENGTH = 1000;
+    public static final int DEFAULT_OBSERVATION_QUEUE_LENGTH = 10000;
 
     private final Oak oak;
 
Index: oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/secondary/SecondaryStoreCacheService.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/secondary/SecondaryStoreCacheService.java	(date 1479998211000)
+++ oak-core/src/main/java/org/apache/jackrabbit/oak/plugins/document/secondary/SecondaryStoreCacheService.java	(revision )
@@ -19,6 +19,12 @@
 
 package org.apache.jackrabbit.oak.plugins.document.secondary;
 
+import static java.util.Arrays.asList;
+import static org.apache.jackrabbit.oak.commons.PropertiesUtil.toBoolean;
+import static org.apache.jackrabbit.oak.commons.PropertiesUtil.toInteger;
+import static org.apache.jackrabbit.oak.commons.PropertiesUtil.toStringArray;
+import static org.apache.jackrabbit.oak.spi.whiteboard.WhiteboardUtils.registerMBean;
+
 import java.util.Collections;
 import java.util.Hashtable;
 import java.util.List;
@@ -57,12 +63,6 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import static java.util.Arrays.asList;
-import static org.apache.jackrabbit.oak.commons.PropertiesUtil.toBoolean;
-import static org.apache.jackrabbit.oak.commons.PropertiesUtil.toInteger;
-import static org.apache.jackrabbit.oak.commons.PropertiesUtil.toStringArray;
-import static org.apache.jackrabbit.oak.spi.whiteboard.WhiteboardUtils.registerMBean;
-
 @Component(label = "Apache Jackrabbit Oak DocumentNodeStateCache Provider",
         metatype = true,
         immediate = true,
@@ -108,7 +108,7 @@
     )
     private static final String PROP_ASYNC_OBSERVER = "enableAsyncObserver";
 
-    private static final int PROP_OBSERVER_QUEUE_SIZE_DEFAULT = 1000;
+    private static final int PROP_OBSERVER_QUEUE_SIZE_DEFAULT = 10000;
     @Property(
             intValue = PROP_OBSERVER_QUEUE_SIZE_DEFAULT,
             label = "Observer queue size",
Index: oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/osgi/RepositoryManager.java
IDEA additional info:
Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP
<+>UTF-8
===================================================================
--- oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/osgi/RepositoryManager.java	(date 1479998211000)
+++ oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/osgi/RepositoryManager.java	(revision )
@@ -63,7 +63,7 @@
         )
 })
 public class RepositoryManager {
-    private static final int DEFAULT_OBSERVATION_QUEUE_LENGTH = 1000;
+    private static final int DEFAULT_OBSERVATION_QUEUE_LENGTH = 10000;
     private static final boolean DEFAULT_COMMIT_RATE_LIMIT = false;
     private static final boolean DEFAULT_FAST_QUERY_RESULT_SIZE = false;