/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/exceptions/ |
H A D | QueryFailedException.java | 52 * @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 D | PartialQueryTask.java | 38 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 D | QueryTask.java | 36 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 D | QueryFailedException.java | 52 * @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 D | PartialQueryTask.java | 37 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 D | QueryTask.java | 35 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 D | ContinuousQueryTask.java | 44 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 D | CTSPersistentStore.java | 193 * @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 D | CTSPersistentStoreImpl.java | 170 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 D | TaskDispatcher.java | 176 * @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 D | CTSPersistentStoreProxy.java | 114 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 D | TokenFilterBuilder.java | 42 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 D | CTSPersistentStore.java | 311 * @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 D | CTSPersistentStoreImpl.java | 219 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 D | TokenFilterBuilder.java | 42 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 D | TaskDispatcher.java | 211 * @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 D | CoreTokenAdapter.java | 157 * @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 D | CTSPersistentStoreProxy.java | 170 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 D | CoreTokenAdapter.java | 168 * @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 D | TaskDispatcherTest.java | 126 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 D | ant.jar | META-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ... |
/forgerock/opendj-b2.6/ext/ant/lib/ |
H A D | ant.jar | META-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ... |
/forgerock/opendj2.6.2/ext/ant/lib/ |
H A D | ant.jar | META-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ... |
/forgerock/opendj2-hg/ext/ant/lib/ |
H A D | ant.jar | META-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 D | ant.jar | META-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ... |