Package org.apache.jackrabbit.oak.plugins.observation2.EventQueueWriter

Examples of org.apache.jackrabbit.oak.plugins.observation2.EventQueueWriter.EventRecorder


        Iterable<ListenerSpec> listenerSpecs = getListenerSpecs(after);
        if (listenerSpecs == null) {
            return DefaultEditor.INSTANCE;
        }

        EventRecorder eventRecorder = new EventRecorder(queue, listenerSpecs);
        return VisibleEditor.wrap(new EventQueueWriter(eventRecorder, "/", after));
    }
View Full Code Here


                .getChildNode(LISTENERS);

        ReadOnlyNodeTypeManager ntMgr = ReadOnlyNodeTypeManager.getInstance(after);
        Set<ListenerSpec> specs = Sets.newHashSet();
        for (ChildNodeEntry listener : listeners.getChildNodeEntries()) {
            ListenerSpec spec = ListenerSpec.create(ntMgr, listener.getName(), listener.getNodeState());
            if (spec != null) {
                specs.add(spec);
            }
        }
View Full Code Here

                defaultWorkspaceName, indexEditors, indexProvider,
                CompositeHook.compose(initHooks));

        // add index hooks later to prevent the OakInitializer to do excessive indexing
        with(new IndexUpdateProvider(indexEditors));
        with(new EventQueueWriterProvider());
        withEditorHook();
        CommitHook commitHook = CompositeHook.compose(commitHooks);
        return new ContentRepositoryImpl(
                store,
                commitHook,
View Full Code Here

                defaultWorkspaceName, indexEditors, indexProvider,
                CompositeHook.compose(initHooks));

        // add index hooks later to prevent the OakInitializer to do excessive indexing
        with(new IndexUpdateProvider(indexEditors));
        with(new EventQueueWriterProvider());
        withEditorHook();
        CommitHook commitHook = CompositeHook.compose(commitHooks);
        return new ContentRepositoryImpl(
                store,
                commitHook,
View Full Code Here

    @Nonnull
    public ObservationManager getObservationManager() {
        if (observationManager == null) {
            if (OAK_775) {
                observationManager = new ObservationManagerImpl2(
                        delegate.getRoot(), namePathMapper, repository.getObservationExecutor());
            } else {
                observationManager = new ObservationManagerImpl(
                    delegate.getRoot(), namePathMapper, repository.getObservationExecutor());
            }
View Full Code Here

    @Nonnull
    public ObservationManager getObservationManager() {
        if (observationManager == null) {
            if (OAK_775) {
                observationManager = new ObservationManagerImpl2(
                        delegate.getRoot(), namePathMapper, repository.getObservationExecutor());
            } else {
                observationManager = new ObservationManagerImpl(
                    delegate.getRoot(), namePathMapper, repository.getObservationExecutor());
            }
View Full Code Here

TOP

Related Classes of org.apache.jackrabbit.oak.plugins.observation2.EventQueueWriter.EventRecorder

Copyright © 2018 www.massapicom. All rights reserved.
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.