Examples of EventFilter


Examples of javax.xml.stream.EventFilter

        XMLEventReader rdr = null;
        try {
            XMLInputFactory f = XMLInputFactory.newInstance();
            XMLEventReader r = f.createXMLEventReader(is);
           
            rdr = f.createFilteredReader(r, new EventFilter() {               
                @Override
                public boolean accept(XMLEvent event) {
                    switch (event.getEventType()) {
                    case XMLEvent.START_ELEMENT:
                    case XMLEvent.END_DOCUMENT:
View Full Code Here

Examples of org.apache.jackrabbit.core.observation.EventFilter

        if (clusterNode == null) {
            throw new UnsupportedRepositoryOperationException();
        }

        ObservationManagerImpl obsMgr = (ObservationManagerImpl) session.getWorkspace().getObservationManager();
        EventFilter filter = obsMgr.createEventFilter(eventTypes, absPath,
                isDeep, uuid, nodeTypeName, false);
        return new EventJournalImpl(filter, clusterNode.getJournal(),
                clusterNode.getId());
    }
View Full Code Here

Examples of org.apache.jackrabbit.oak.plugins.observation.EventFilter

    }

    @Override
    public synchronized void addEventListener(EventListener listener, int eventTypes, String absPath,
            boolean isDeep, String[] uuid, String[] nodeTypeName, boolean noLocal) throws RepositoryException {
        EventFilter filter = new EventFilter(ntMgr, eventTypes, oakPath(absPath), isDeep,
                uuid, validateNodeTypeNames(nodeTypeName), noLocal);
        ChangeProcessor processor = processors.get(listener);
        if (processor == null) {
            log.info(OBSERVATION, "Registering event listener {} with filter {}", listener, filter);
            ListenerTracker tracker = new ListenerTracker(
View Full Code Here

Examples of org.apache.jackrabbit.oak.plugins.observation.filter.EventFilter

            try {
                FilterProvider provider = filterProvider.get();
                // FIXME don't rely on toString for session id
                if (provider.includeCommit(contentSession.toString(), info)) {
                    String basePath = provider.getPath();
                    EventFilter userFilter = provider.getFilter(previousRoot, root);
                    EventFilter acFilter = new ACFilter(previousRoot, root, permissionProvider, basePath);
                    ImmutableTree beforeTree = getTree(previousRoot, basePath);
                    ImmutableTree afterTree = getTree(root, basePath);
                    EventIterable<Event> events = new EventIterable<Event>(
                            beforeTree.getNodeState(), afterTree.getNodeState(),
                            Filters.all(userFilter, acFilter),
View Full Code Here

Examples of org.apache.jackrabbit.oak.plugins.observation.filter.EventFilter

     * @param before  before state of the child node
     * @param after  after state of the child node
     * @return {@code EventGenerator} for a child node
     */
    protected EventGenerator createChildGenerator(String name, NodeState before, NodeState after) {
        EventFilter childFilter = filter.create(name, before, after);
        if (childFilter != null) {
            return new EventGenerator(
                    childFilter,
                    listener.create(name, before, after));
        } else {
View Full Code Here

Examples of org.apache.jackrabbit.oak.plugins.observation.filter.EventFilter

    //------------------------------------------------------------< EventGenerator >---

    @Override
    protected EventGenerator createChildGenerator(String name, NodeState before, NodeState after) {
        EventFilter childFilter = filter.create(name, before, after);
        if (childFilter != null) {
            childEvents.add(new EventIterable<T>(
                    before, after,
                    childFilter,
                    listener.create(name, before, after)));
View Full Code Here

Examples of org.apache.jackrabbit.oak.plugins.observation.filter.EventFilter

            try {
                FilterProvider provider = filterProvider.get();
                // FIXME don't rely on toString for session id
                if (provider.includeCommit(contentSession.toString(), info)) {
                    String basePath = provider.getPath();
                    EventFilter userFilter = provider.getFilter(previousRoot, root);
                    EventFilter acFilter = new ACFilter(previousRoot, root, permissionProvider, basePath);
                    EventQueue events = new EventQueue(
                            namePathMapper, info, previousRoot, root, basePath,
                            Filters.all(userFilter, acFilter));
                    if (events.hasNext() && runningMonitor.enterIf(running)) {
                        try {
View Full Code Here

Examples of org.apache.jackrabbit.oak.plugins.observation.filter.EventFilter

    }

    @Override @CheckForNull
    public EventHandler getChildHandler(
            String name, NodeState before, NodeState after) {
        EventFilter f = filter.create(name, before, after);
        if (f != null) {
            EventHandler h = handler.getChildHandler(name, before, after);
            if (h != null) {
                return new FilteredHandler(f, h);
            }
View Full Code Here

Examples of org.apache.jackrabbit.oak.plugins.observation.filter.EventFilter

            try {
                FilterProvider provider = filterProvider.get();
                // FIXME don't rely on toString for session id
                if (provider.includeCommit(contentSession.toString(), info)) {
                    String basePath = provider.getPath();
                    EventFilter userFilter = provider.getFilter(previousRoot, root);
                    EventFilter acFilter = new ACFilter(previousRoot, root, permissionProvider, basePath);
                    EventQueue events = new EventQueue(
                            namePathMapper, info, previousRoot, root, basePath,
                            Filters.all(userFilter, acFilter));
                    if (events.hasNext() && runningMonitor.enterIf(running)) {
                        try {
View Full Code Here

Examples of org.apache.jackrabbit.spi.EventFilter

    public HierarchyEventListener(WorkspaceManager wspManager,
                                  HierarchyManager hierarchyMgr,
                                  CacheBehaviour cacheBehaviour) {
        this.hierarchyMgr = hierarchyMgr;
        if (cacheBehaviour == CacheBehaviour.OBSERVATION) {
            EventFilter filter = null;
            try {
                // listen to all events except 'local' ones
                Path root = wspManager.getPathFactory().getRootPath();
                filter = wspManager.createEventFilter(Event.ALL_TYPES, root, true, null, null, true);
            } catch (RepositoryException e) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.