Package javax.jcr.observation

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

214
215
216
217
218
219
220
221
222
223
224
                        synchronized (Locked.this) {
                            Locked.this.notify();
                        }
                    }
                };
                om.addEventListener(listener, Event.PROPERTY_REMOVED,
                        lockable.getPath(), false, null, null, true);
            }

            // now keep trying to acquire the lock
            // using 'this' as a monitor allows the event listener to notify
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
        Session s = getHelper().getReadOnlySession(workspaceName);
        try {
            EventResult listener = new EventResult(log);
            ObservationManager obsMgr = s.getWorkspace().getObservationManager();
            obsMgr.addEventListener(listener, Event.NODE_ADDED, "/", true,
                    null, null, false);
            Version v = n1.checkin();
            obsMgr.removeEventListener(listener);

            Event[] events = listener.getEvents(1000);
View Full Code Here
315
316
317
318
319
320
321
322
323
324
325
        // testUser registers a event listener for 'path
        ObservationManager obsMgr = testSession.getWorkspace().getObservationManager();
        EventResult listener = new EventResult(((JUnitTest) this).log);
        try {
            obsMgr.addEventListener(listener, Event.NODE_REMOVED, path, true, new String[0], new String[0], true);

            // superuser removes the node with childNPath in order to provoke
            // events being generated
            superuser.getItem(childNPath).remove();
            superuser.save();
View Full Code Here
1455
1456
1457
1458
1459
1460
1461
1462
1463
1464
1465
        final List<Event> failedEvents = new ArrayList<Event>();
        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
1571
1572
1573
1574
1575
1576
1577
1578
1579
1580
1581
        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
1667
1668
1669
1670
1671
1672
1673
1674
1675
1676
1677
                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<Void> disposer = new FutureTask<Void>(new Callable<Void>() {
            @Override
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
        Session s = getHelper().getSuperuserSession();
        ObservationManager mgr = s.getWorkspace().getObservationManager();
        EventResult result = new EventResult(log);

        try {
            mgr.addEventListener(result, Event.PERSIST|Event.NODE_ADDED|Event.NODE_MOVED|Event.NODE_REMOVED, testRootNode.getPath(), true, null, null, false);

            NodeIterator it = testRootNode.getNodes();

            Node n = it.nextNode();
            String name = n.getName();
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
        EventCounter el = new EventCounter();
        ObservationManager om = superuser.getWorkspace().getObservationManager();

        // add node underneath shared set: verify it generates one event only
        om.addEventListener(el, Event.NODE_ADDED, testRootNode.getPath(),
                true, null, null, false);
        b1.addNode("c");
        b1.save();
        superuser.getWorkspace().getObservationManager().removeEventListener(el);
        assertEquals(1, el.getEventCount());
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        superuser.getWorkspace().getObservationManager().removeEventListener(el);
        assertEquals(1, el.getEventCount());

        // remove node underneath shared set: verify it generates one event only
        el.resetCount();
        om.addEventListener(el, Event.NODE_REMOVED, testRootNode.getPath(),
                true, null, null, false);
        b1.getNode("c").remove();
        b1.save();
        superuser.getWorkspace().getObservationManager().removeEventListener(el);
        assertEquals(1, el.getEventCount());
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
        superuser.getWorkspace().getObservationManager().removeEventListener(el);
        assertEquals(1, el.getEventCount());

        // add property underneath shared set: verify it generates one event only
        el.resetCount();
        om.addEventListener(el, Event.PROPERTY_ADDED, testRootNode.getPath(),
                true, null, null, false);
        b1.setProperty("c", "1");
        b1.save();
        superuser.getWorkspace().getObservationManager().removeEventListener(el);
        assertEquals(1, el.getEventCount());
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.