Examples of javax.jcr.observation.ObservationManager.addEventListener()

Class javax.jcr.observation.ObservationManager

Examples of javax.jcr.observation.ObservationManager.addEventListener()

javax.jcr.observation.ObservationManager.addEventListener()

        final AtomicReference<CountDownLatch> eventCount = new AtomicReference<CountDownLatch>();


        final Session observingSession = createAnonymousSession();
        try {
            ObservationManager obsMgr = observingSession.getWorkspace().getObservationManager();
            obsMgr.addEventListener(new EventListener() {
                @Override
                public void onEvent(EventIterator events) {
                    while (events.hasNext()) {
                        Event event = events.nextEvent();
                        try {

View Full Code Here

                        }
                    }
                }
            };


            obsMgr.addEventListener(listener, Event.NODE_ADDED | Event.NODE_REMOVED | Event.NODE_MOVED |
                    Event.PROPERTY_ADDED | Event.PROPERTY_REMOVED | Event.PROPERTY_CHANGED | Event.PERSIST,
                    "/", true, null, null, false);


            // Generate two events
            Node n = getNode(TEST_PATH);

View Full Code Here

                        hasEvents.get().countDown();
                    }
                }
            };


            obsMgr.addEventListener(listener, Event.PROPERTY_ADDED,
                    "/", true, null, null, false);


            // add property to root node
            Node root = getNode("/");
            root.setProperty("prop", "value");

View Full Code Here


        final List<Event> failedEvents = new ArrayList<Event>();


        ObservationManager obsMgr = getSession().getWorkspace().getObservationManager();
        obsMgr.setUserData("my user data");
        obsMgr.addEventListener(new EventListener() {
                @Override
                public void onEvent(EventIterator events) {
                    while (events.hasNext()) {
                        Event event = events.nextEvent();
                        try {

View Full Code Here


        final List<Event> failedEvents = new ArrayList<Event>();


        ObservationManager obsMgr = getSession().getWorkspace().getObservationManager();
        obsMgr.setUserData("my user data");
        obsMgr.addEventListener(new EventListener() {
                @Override
                public void onEvent(EventIterator events) {
                    while (events.hasNext()) {
                        Event event = events.nextEvent();
                        try {

View Full Code Here

    public void observationNoEvents() throws RepositoryException, InterruptedException {
        final List<Event> failedEvents = new ArrayList<Event>();


        ObservationManager obsMgr = getSession().getWorkspace().getObservationManager();
        obsMgr.setUserData("my user data");
        obsMgr.addEventListener(new EventListener() {
                @Override
                public void onEvent(EventIterator events) {
                    while (events.hasNext()) {
                        failedEvents.add(events.nextEvent());
                    }

View Full Code Here

                while (events.hasNext()) {
                    failedEvents.add(events.nextEvent());
                }
            }
        };
        obsMgr.addEventListener(listener, Event.NODE_ADDED | Event.NODE_REMOVED | Event.NODE_MOVED |
            Event.PROPERTY_ADDED | Event.PROPERTY_REMOVED | Event.PROPERTY_CHANGED | Event.PERSIST,
            "/", true, null, null, false);


        FutureTask<Object> disposer = new FutureTask<Object>(new Callable<Object>() {
            @Override

View Full Code Here

                SystemSession defSysSession = getSystemSession(wspName);
                systemSearchMgr = new SearchManager(repConfig.getSearchConfig(),
                        nsReg, ntReg, defSysSession.getItemStateManager(),
                        vMgr.getPersistenceManager(), SYSTEM_ROOT_NODE_ID, null, null);
                ObservationManager obsMgr = defSysSession.getWorkspace().getObservationManager();
                obsMgr.addEventListener(systemSearchMgr, Event.NODE_ADDED
                        | Event.NODE_REMOVED | Event.PROPERTY_ADDED
                        | Event.PROPERTY_CHANGED | Event.PROPERTY_REMOVED,
                        "/" + defSysSession.getJCRName(NameConstants.JCR_SYSTEM),
                        true, null, null, false);
            }

View Full Code Here

                        nsReg, ntReg, getWorkspaceInfo(wspName).itemStateMgr,
                        vMgr.getPersistenceManager(), SYSTEM_ROOT_NODE_ID, null, null);


                SystemSession defSysSession = getSystemSession(wspName);
                ObservationManager obsMgr = defSysSession.getWorkspace().getObservationManager();
                obsMgr.addEventListener(systemSearchMgr, Event.NODE_ADDED
                        | Event.NODE_REMOVED | Event.PROPERTY_ADDED
                        | Event.PROPERTY_CHANGED | Event.PROPERTY_REMOVED,
                        "/" + defSysSession.getJCRName(NameConstants.JCR_SYSTEM),
                        true, null, null, false);
            }

View Full Code Here


                ObservationManager observationManager = workspace.getObservationManager();
                for (DefaultEventListener listener : l) {
                    if (listener.getEventTypes() > 0) {
                        listener.setWorkspace(ws);
                        observationManager.addEventListener(listener, listener.getEventTypes(),
                                listener.getPath(), listener.isDeep(), listener.getUuids(),
                                listener.getNodeTypes(), false);
                    } else {
                        logger.info("Skipping listener {} as it has no event types configured.",
                                listener.getClass().getName());

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.