Index: oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java
===================================================================
--- oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java	(revision 1759223)
+++ oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ChangeProcessor.java	(working copy)
@@ -237,7 +237,10 @@
                         }
                         commitRateLimiter.blockCommits();
                     } else if (!blocking) {
-                        LOG.warn("Revision queue is full. Further revisions will be compacted.");
+                        // do not log if queue length is set to one
+                        if (queueLength > 1) {
+                            LOG.warn("Revision queue is full. Further revisions will be compacted.");
+                        }
                     }
                     blocking = true;
                 } else {
Index: oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ObservationManagerImpl.java
===================================================================
--- oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ObservationManagerImpl.java	(revision 1759223)
+++ oak-jcr/src/main/java/org/apache/jackrabbit/oak/jcr/observation/ObservationManagerImpl.java	(working copy)
@@ -138,8 +138,14 @@
         }
     }
 
+    private void addEventListener(EventListener listener,
+                                  ListenerTracker tracker,
+                                  FilterProvider filterProvider) {
+        addEventListener(listener, tracker, filterProvider, queueLength);
+    }
+
     private synchronized void addEventListener(EventListener listener, ListenerTracker tracker,
-            FilterProvider filterProvider) {
+            FilterProvider filterProvider, int queueLength) {
 
         ChangeProcessor processor = processors.get(listener);
         if (processor == null) {
@@ -150,7 +156,7 @@
             // session. See OAK-1368.
             processor = new ChangeProcessor(sessionDelegate.getContentSession(), namePathMapper,
                     tracker, filterProvider, statisticManager, queueLength,
-                    commitRateLimiter);
+                    queueLength > 1 ? commitRateLimiter : null);
             processors.put(listener, processor);
             processor.start(whiteboard);
         } else {
@@ -216,6 +222,8 @@
         boolean noLocal = filter.getNoLocal();
         boolean noExternal = filter.getNoExternal() || listener instanceof ExcludeExternal;
         boolean noInternal = filter.getNoInternal();
+        boolean consolidate = filter.getConsolidateChanges();
+        int queueLen = consolidate ? 1 : queueLength;
         Set<String> includePaths = getOakPaths(namePathMapper, filter.getAdditionalPaths());
         String absPath = filter.getAbsPath();
         if (absPath != null) {
@@ -256,7 +264,7 @@
         ListenerTracker tracker = new WarningListenerTracker(
                 !noExternal, listener, eventTypes, absPath, isDeep, uuids, nodeTypeName, noLocal);
 
-        addEventListener(listener, tracker, filterBuilder.build());
+        addEventListener(listener, tracker, filterBuilder.build(), queueLen);
     }
 
     private static List<Condition> createExclusions(FilterBuilder filterBuilder, Iterable<String> excludedPaths) {