Package javax.jcr.observation

Examples of javax.jcr.observation.EventJournal.skipTo()

1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
1112
1113
1114
1115
1116
1117
1118
1119
1120
1121
1122
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
1137
1138
1139
1140
1141
1142
1143
1144
1145
1146
1147
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
1193
1194
1195
1196
1197
1198
1199
1200
1201
1202
1203
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
1140
1141
1142
1143
1144
1145
1146
1147
1148
1149
1150
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
1106
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
1120
1121
1122
1123
1124
1125
1126
1127
1128
1129
1130
        if (journal == null) {
            throw new UnsupportedRepositoryOperationException();
        }
        EventFactory factory = new EventFactory(sInfo.getSession(),
                sInfo.getNamePathResolver(), idFactory, qValueFactory);
        journal.skipTo(after);
        List<Event> events = new ArrayList<Event>();
        int batchSize = 1024;
        boolean distinctDates = true;
        long lastDate = Long.MIN_VALUE;
        while (journal.hasNext() && (batchSize > 0 || !distinctDates)) {
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
        session.getRootNode().addNode("testNode");
        session.save();
        session.getNode("/testNode").remove();
        session.save();
        EventJournal eventJournal = session.getWorkspace().getObservationManager().getEventJournal();
        eventJournal.skipTo(now);
        List<String> paths = new ArrayList<>();
        while (eventJournal.hasNext()) {
            paths.add(((Event)eventJournal.next()).getPath());
        }
        //check the node-added event is there
View Full Code Here
2199
2200
2201
2202
2203
2204
2205
2206
2207
2208
2209
        session.save();
        Thread.sleep(100);
        long afterNode3 = System.currentTimeMillis();

        EventJournal journal = getObservationManager().getEventJournal();
        journal.skipTo(startingDate);
        assertPathsInJournal(journal, true,
                             "/testroot/node1", "/testroot/node1/jcr:primaryType",
                             "/testroot/node2", "/testroot/node2/jcr:primaryType",
                             "/testroot/node3", "/testroot/node3/jcr:primaryType");
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.