List of delayIfEventQueueOverloaded() Examples

Examples of delayIfEventQueueOverloaded()

org.apache.jackrabbit.core.observation.ObservationDispatcher.delayIfEventQueueOverloaded()
Checks if the observation event queue contains more than the configured {@link #MAX_QUEUED_EVENTS maximum number of events}, and delays the current thread in such cases. No delay is added if the current thread is the observation thread, for example if an observation listener writes to the repository.
This method should only be called outside the scope of internal repository access locks.

Examples of org.apache.jackrabbit.core.observation.ObservationDispatcher.delayIfEventQueueOverloaded()

            if (isOutermostWriteOperation) {
                WorkspaceManager manager =
                    context.getRepositoryContext().getWorkspaceManager();
                ObservationDispatcher dispatcher =
                    manager.getObservationDispatcher(context.getWorkspace().getName());
                dispatcher.delayIfEventQueueOverloaded();
            }
        }
    }


    /**

View Full Code Here

Examples of org.apache.jackrabbit.core.observation.ObservationDispatcher.delayIfEventQueueOverloaded()

            if (isOutermostWriteOperation) {
                WorkspaceManager manager =
                    context.getRepositoryContext().getWorkspaceManager();
                ObservationDispatcher dispatcher =
                    manager.getObservationDispatcher(context.getWorkspace().getName());
                dispatcher.delayIfEventQueueOverloaded();
            }
        }
    }


    /**

View Full Code Here

Examples of org.apache.jackrabbit.core.observation.ObservationDispatcher.delayIfEventQueueOverloaded()

            if (isOutermostWriteOperation) {
                WorkspaceManager manager =
                    context.getRepositoryContext().getWorkspaceManager();
                ObservationDispatcher dispatcher =
                    manager.getObservationDispatcher(context.getWorkspace().getName());
                dispatcher.delayIfEventQueueOverloaded();
            }
        }
    }


    /**

View Full Code Here

Examples of org.apache.jackrabbit.core.observation.ObservationDispatcher.delayIfEventQueueOverloaded()

            if (isOutermostWriteOperation) {
                WorkspaceManager manager =
                    context.getRepositoryContext().getWorkspaceManager();
                ObservationDispatcher dispatcher =
                    manager.getObservationDispatcher(context.getWorkspace().getName());
                dispatcher.delayIfEventQueueOverloaded();
            }
        }
    }


    /**

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.