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

123456

/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/
H A DReader.java36 BlockingQueue<Change> queue; field in class:Reader
40 this.queue = q;
202 // Write the change in the queue
204 queue.put(change);
259 // clear the queue of changes
260 queue.clear();
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/
H A DReader.java35 BlockingQueue<Change> queue; field in class:Reader
39 this.queue = q;
201 // Write the change in the queue
203 queue.put(change);
258 // clear the queue of changes
259 queue.clear();
/forgerock/opendj2.6.2/tests/staf-tests/shared/java/ldapjdk/
H A DReader.java36 BlockingQueue<Change> queue; field in class:Reader
40 this.queue = q;
202 // Write the change in the queue
204 queue.put(change);
259 // clear the queue of changes
260 queue.clear();
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/java/ldapjdk/
H A DReader.java36 BlockingQueue<Change> queue; field in class:Reader
40 this.queue = q;
202 // Write the change in the queue
204 queue.put(change);
259 // clear the queue of changes
260 queue.clear();
/forgerock/opendj2-hg/tests/staf-tests/shared/java/ldapjdk/
H A DReader.java35 BlockingQueue<Change> queue; field in class:Reader
39 this.queue = q;
201 // Write the change in the queue
203 queue.put(change);
258 // clear the queue of changes
259 queue.clear();
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/
H A Dpackage-info.java21 package org.forgerock.openam.cts.impl.queue.config;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A Dpackage-info.java18 * Classes responsible for managing the asynchronous task queue which is used by the CTS to
23 package org.forgerock.openam.cts.impl.queue;
H A DQueueSelector.java16 package org.forgerock.openam.cts.impl.queue;
21 * QueueSelector is responsible for selecting an appropriate asynchronous queue for
25 * are processed by the same queue. By enforcing this invariant, we can be certain that
H A DAsyncResultHandler.java16 package org.forgerock.openam.cts.impl.queue;
37 * The processed result is placed on the queue when available. At which point either
38 * the caller is already waiting, or can begin to wait for the result. The queue
55 * Creates an instance of the {@link ResultHandler} with a default queue.
68 * @param queue Custom queue implementation if required.
71 AsyncResultHandler(QueueConfiguration config, BlockingQueue<Object> queue, Debug debug) { argument
73 this.syncQueue = queue;
116 * @throws IllegalStateException If there is already a value on the queue.
H A DAsyncResultHandlerFactory.java16 package org.forgerock.openam.cts.impl.queue;
45 * @param config Required for queue configuration.
H A DDeleteOnQueryResultHandler.java16 package org.forgerock.openam.cts.impl.queue;
H A DResultHandlerFactory.java16 package org.forgerock.openam.cts.impl.queue;
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/
H A Dpackage-info.java21 package org.forgerock.openam.cts.impl.queue.config;
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A Dpackage-info.java18 * Classes responsible for managing the asynchronous task queue which is used by the CTS to
23 package org.forgerock.openam.cts.impl.queue;
H A DQueueSelector.java16 package org.forgerock.openam.cts.impl.queue;
21 * QueueSelector is responsible for selecting an appropriate asynchronous queue for
25 * are processed by the same queue. By enforcing this invariant, we can be certain that
H A DAsyncResultHandler.java16 package org.forgerock.openam.cts.impl.queue;
37 * The processed result is placed on the queue when available. At which point either
38 * the caller is already waiting, or can begin to wait for the result. The queue
55 * Creates an instance of the {@link ResultHandler} with a default queue.
68 * @param queue Custom queue implementation if required.
71 AsyncResultHandler(QueueConfiguration config, BlockingQueue<Object> queue, Debug debug) { argument
73 this.syncQueue = queue;
116 * @throws IllegalStateException If there is already a value on the queue.
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorThreadFactory.java44 * @param queue Non null BlockingQueue to assign.
48 public SeriesTaskExecutorThread create(BlockingQueue<Task> queue) { argument
49 Reject.ifNull(queue);
51 processor.setQueue(queue);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorThreadFactory.java44 * @param queue Non null BlockingQueue to assign.
48 public SeriesTaskExecutorThread create(BlockingQueue<Task> queue) { argument
49 Reject.ifNull(queue);
51 processor.setQueue(queue);
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcherTest.java16 package org.forgerock.openam.cts.impl.queue;
34 private TaskDispatcher queue; field in class:TaskDispatcherTest
49 queue = new TaskDispatcher(
56 queue.startDispatcher();
62 queue.create(null, mockHandler);
67 queue.update(null, mockHandler);
72 queue.delete(null, mockHandler);
77 queue.read(null, null);
82 queue.query(null, null);
87 queue
[all...]
H A DQueueSelectorTest.java16 package org.forgerock.openam.cts.impl.queue;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/queue/
H A DDefaultMonitoringResultHandler.java16 package org.forgerock.openam.cts.monitoring.impl.queue;
H A DTokenMonitoringResultHandler.java16 package org.forgerock.openam.cts.monitoring.impl.queue;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/reaper/
H A DTokenDeletion.java20 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
34 private final TaskDispatcher queue; field in class:TokenDeletion
37 public TokenDeletion(TaskDispatcher queue) { argument
38 this.queue = queue;
57 queue.delete(token, handler);
/forgerock/openam-v13/openam-shared/src/main/java/com/sun/identity/shared/
H A DBufferedIterator.java44 private final BlockingQueue<T> queue = new LinkedBlockingQueue<T>(); field in class:BufferedIterator
48 queue.add(entry);
52 queue.addAll(entry);
62 return queue.take();
71 return !(done && queue.isEmpty());
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/config/
H A DCTSQueueConfigurationTest.java16 package org.forgerock.openam.cts.impl.queue.config;

Completed in 103 milliseconds

123456