Searched defs:tokenFilter (Results 1 - 25 of 25) sorted by relevance

/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/exceptions/
H A DQueryFailedException.java52 * @param tokenFilter The filter used for the query.
55 public QueryFailedException(TokenFilter tokenFilter, Exception e) { argument
61 tokenFilter),
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/
H A DPartialQueryTask.java38 private final TokenFilter tokenFilter; field in class:PartialQueryTask
41 * @param tokenFilter Non null and must define at least one Return Attribute.
44 public PartialQueryTask(TokenFilter tokenFilter, ResultHandler<Collection<PartialToken>, ?> handler) { argument
46 this.tokenFilter = tokenFilter;
58 Reject.ifTrue(tokenFilter.getReturnFields().isEmpty());
60 handler.processResults(adapter.partialQuery(connection, tokenFilter));
65 return "PartialQueryTask: " + tokenFilter;
H A DQueryTask.java36 private final TokenFilter tokenFilter; field in class:QueryTask
39 * @param tokenFilter Non null and must not define any Return Attributes.
42 public QueryTask(TokenFilter tokenFilter, ResultHandler<Collection<Token>, ?> handler) { argument
44 this.tokenFilter = tokenFilter;
63 Reject.ifFalse(tokenFilter.getReturnFields().isEmpty());
64 handler.processResults(adapter.query(connection, tokenFilter));
69 return MessageFormat.format("QueryTask: {0}", tokenFilter);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/exceptions/
H A DQueryFailedException.java52 * @param tokenFilter The filter used for the query.
55 public QueryFailedException(TokenFilter tokenFilter, Exception e) { argument
61 tokenFilter),
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/
H A DPartialQueryTask.java37 private final TokenFilter tokenFilter; field in class:PartialQueryTask
40 * @param tokenFilter Non null and must define at least one Return Attribute.
43 public PartialQueryTask(TokenFilter tokenFilter, ResultHandler<Collection<PartialToken>, ?> handler) { argument
45 this.tokenFilter = tokenFilter;
57 Reject.ifTrue(tokenFilter.getReturnFields().isEmpty());
59 handler.processResults(adapter.partialQuery(tokenFilter));
64 return "PartialQueryTask: " + tokenFilter;
H A DQueryTask.java35 private final TokenFilter tokenFilter; field in class:QueryTask
38 * @param tokenFilter Non null and must not define any Return Attributes.
41 public QueryTask(TokenFilter tokenFilter, ResultHandler<Collection<Token>, ?> handler) { argument
43 this.tokenFilter = tokenFilter;
61 Reject.ifFalse(tokenFilter.getReturnFields().isEmpty());
62 handler.processResults(adapter.query(tokenFilter));
67 return MessageFormat.format("QueryTask: {0}", tokenFilter);
H A DContinuousQueryTask.java44 private final TokenFilter tokenFilter; field in class:ContinuousQueryTask
52 * @param tokenFilter The filter to be continually applied in the datastore layer.
55 public ContinuousQueryTask(TokenFilter tokenFilter, ContinuousQueryListener listener) { argument
57 this.tokenFilter = tokenFilter;
75 queryPromise.tryHandleResult(adapter.startContinuousQuery(tokenFilter, listener));
88 return MessageFormat.format("ContinuousQueryTask: {0}", tokenFilter);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/
H A DCTSPersistentStore.java193 * @param tokenFilter Non null TokenFilter, with the return attributes defined.
198 Collection<PartialToken> attributeQuery(TokenFilter tokenFilter) throws CoreTokenException; argument
205 * @param tokenFilter Non null filter.
209 void deleteOnQueryAsync(TokenFilter tokenFilter) throws CoreTokenException; argument
H A DCTSPersistentStoreImpl.java170 public Collection<Token> query(TokenFilter tokenFilter) throws CoreTokenException { argument
171 debug("Query: {0}", tokenFilter.toString());
172 return adapter.query(tokenFilter);
176 public Collection<PartialToken> attributeQuery(TokenFilter tokenFilter) throws CoreTokenException { argument
177 debug("AttributeQuery: {0}", tokenFilter.toString());
178 return adapter.attributeQuery(tokenFilter);
182 public void deleteOnQueryAsync(TokenFilter tokenFilter) throws CoreTokenException { argument
183 debug("DeleteOnQuery: with query {0}", tokenFilter.toString());
184 adapter.deleteOnQuery(tokenFilter);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcher.java176 * @param tokenFilter Non null TokenFilter.
181 public void query(TokenFilter tokenFilter, ResultHandler<Collection<Token>, ?> handler) throws CoreTokenException { argument
182 Reject.ifNull(tokenFilter, handler);
184 taskExecutor.execute(null, taskFactory.query(tokenFilter, handler));
202 * @param tokenFilter Non null TokenFilter.
207 public void partialQuery(TokenFilter tokenFilter, ResultHandler<Collection<PartialToken>, ?> handler) throws CoreTokenException { argument
208 Reject.ifNull(tokenFilter, handler);
210 taskExecutor.execute(null, taskFactory.partialQuery(tokenFilter, handler));
/forgerock/openam-v13/openam-rest/src/main/java/org/forgerock/openam/rest/router/
H A DCTSPersistentStoreProxy.java114 public Collection<PartialToken> attributeQuery(TokenFilter tokenFilter) throws CoreTokenException { argument
115 return CTSHolder.get().attributeQuery(tokenFilter);
119 public void deleteOnQueryAsync(TokenFilter tokenFilter) throws CoreTokenException { argument
120 CTSHolder.get().deleteOnQueryAsync(tokenFilter);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/api/filter/
H A DTokenFilterBuilder.java42 private TokenFilter tokenFilter = new TokenFilter(); field in class:TokenFilterBuilder
53 return new FilterAttributeBuilder(tokenFilter, Type.AND);
61 return new FilterAttributeBuilder(tokenFilter, Type.OR);
76 return new FilterAttributeBuilder(tokenFilter, Type.AND).withAttribute(field, value);
92 tokenFilter.setQuery(query);
105 tokenFilter.addReturnAttribute(field);
113 if (tokenFilter.getQuery() == null) {
114 tokenFilter.setQuery(QueryFilter.<CoreTokenField>alwaysTrue());
116 return tokenFilter;
126 private FilterAttributeBuilder(TokenFilter tokenFilter, Typ argument
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/
H A DCTSPersistentStore.java311 * @param tokenFilter Non null TokenFilter, with the return attributes defined.
315 Collection<PartialToken> attributeQuery(TokenFilter tokenFilter) throws CoreTokenException; argument
322 * @param tokenFilter Non null filter.
325 void deleteOnQueryAsync(TokenFilter tokenFilter) throws CoreTokenException; argument
H A DCTSPersistentStoreImpl.java219 public void addContinuousQueryListener(ContinuousQueryListener listener, TokenFilter tokenFilter) argument
221 debug("Add ContinuousQueryListener to {0}", tokenFilter.toString());
222 adapter.continuousQuery(listener, tokenFilter);
226 public void removeContinuousQueryListener(ContinuousQueryListener listener, TokenFilter tokenFilter) argument
228 debug("Remove ContinuousQueryListener from {0}", tokenFilter.toString());
229 adapter.removeContinuousQueryListener(listener, tokenFilter);
233 public void stopContinuousQuery(TokenFilter tokenFilter) { argument
234 debug("Stopping ContinuousQuery for {0}", tokenFilter.toString());
235 adapter.stopContinuousQuery(tokenFilter);
239 public Collection<Token> query(TokenFilter tokenFilter) throw argument
245 attributeQuery(TokenFilter tokenFilter) argument
251 deleteOnQueryAsync(TokenFilter tokenFilter) argument
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/api/filter/
H A DTokenFilterBuilder.java42 private TokenFilter tokenFilter = new TokenFilter(); field in class:TokenFilterBuilder
53 return new FilterAttributeBuilder(tokenFilter, Type.AND);
61 return new FilterAttributeBuilder(tokenFilter, Type.OR);
76 return new FilterAttributeBuilder(tokenFilter, Type.AND).withAttribute(field, value);
92 tokenFilter.setQuery(query);
104 tokenFilter.setSizeLimit(sizeLimit);
116 tokenFilter.setTimeLimit(timeLimit);
129 tokenFilter.addReturnAttribute(field);
137 if (tokenFilter.getQuery() == null) {
138 tokenFilter
150 FilterAttributeBuilder(TokenFilter tokenFilter, Type type) argument
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcher.java211 * @param tokenFilter Non null TokenFilter.
216 public void query(TokenFilter tokenFilter, ResultHandler<Collection<Token>, ?> handler) throws CoreTokenException { argument
217 Reject.ifNull(tokenFilter, handler);
219 taskExecutor.execute(null, taskFactory.query(tokenFilter, handler));
236 * @param tokenFilter Non null TokenFilter.
241 public void partialQuery(TokenFilter tokenFilter, ResultHandler<Collection<PartialToken>, ?> handler) argument
243 Reject.ifNull(tokenFilter, handler);
245 taskExecutor.execute(null, taskFactory.partialQuery(tokenFilter, handler));
267 * @param tokenFilter Non null TokenFilter.
271 public void continuousQuery(final ContinuousQueryListener listener, TokenFilter tokenFilter) argument
309 removeContinuousQueryListener(final ContinuousQueryListener listener, TokenFilter tokenFilter) argument
335 stopContinuousQuery(TokenFilter tokenFilter) argument
[all...]
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/
H A DCoreTokenAdapter.java157 * @param tokenFilter A non null TokenFilter.
163 public Collection<Token> query(final TokenFilter tokenFilter) throws CoreTokenException { argument
164 debug("Query: queued with Filter: {0}", tokenFilter);
166 dispatcher.query(tokenFilter, handler);
172 debug("Query: returned {0} Tokens with Filter: {1}", tokens.size(), tokenFilter);
175 throw new QueryFailedException(tokenFilter, e);
/forgerock/openam/openam-rest/src/main/java/org/forgerock/openam/rest/router/
H A DCTSPersistentStoreProxy.java170 public Collection<PartialToken> attributeQuery(TokenFilter tokenFilter) throws CoreTokenException { argument
171 return CTSHolder.get().attributeQuery(tokenFilter);
175 public void deleteOnQueryAsync(TokenFilter tokenFilter) throws CoreTokenException { argument
176 CTSHolder.get().deleteOnQueryAsync(tokenFilter);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/
H A DCoreTokenAdapter.java168 * @param tokenFilter A non null TokenFilter.
174 public Collection<Token> query(final TokenFilter tokenFilter) throws CoreTokenException { argument
175 debug("Query: queued with Filter: {0}", tokenFilter);
177 dispatcher.query(tokenFilter, handler);
183 debug("Query: returned {0} Tokens with Filter: {1}", tokens.size(), tokenFilter);
186 throw new QueryFailedException(tokenFilter, e);
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcherTest.java126 public void shouldRejectNullArgsOnQuery(TokenFilter tokenFilter, ResultHandler<Collection<Token>, ?> handler) argument
128 queue.query(tokenFilter, handler);
132 public void shouldRejectNullArgsOnPartialQuery(TokenFilter tokenFilter, argument
134 queue.partialQuery(tokenFilter, handler);
/forgerock/opendj2/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj-b2.6/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj2.6.2/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj2-hg/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj-v3/opendj-server-legacy/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...

Completed in 59 milliseconds