/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/queue/ |
H A D | MonitoredResultHandlerFactory.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue; 22 import org.forgerock.openam.cts.impl.queue.AsyncResultHandlerFactory; 24 import org.forgerock.openam.cts.impl.queue.ResultHandlerFactory;
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorThreadTest.java | 80 BlockingQueue<Task> queue = mock(BlockingQueue.class); 81 given(queue.take()).willAnswer(new Answer<Object>() { 88 return queue;
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/ |
H A D | AsyncResultHandler.java | 16 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 D | ResultHandlerFactory.java | 16 package org.forgerock.openam.cts.impl.queue;
|
H A D | DeleteOnQueryResultHandler.java | 16 package org.forgerock.openam.cts.impl.queue;
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/queue/ |
H A D | MonitoredResultHandlerFactory.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue; 22 import org.forgerock.openam.cts.impl.queue.AsyncResultHandlerFactory; 24 import org.forgerock.openam.cts.impl.queue.ResultHandlerFactory;
|
H A D | DefaultMonitoringResultHandler.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/ |
H A D | AsyncResultHandler.java | 16 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 D | ResultHandlerFactory.java | 16 package org.forgerock.openam.cts.impl.queue;
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/ |
H A D | QueueSelectorTest.java | 16 package org.forgerock.openam.cts.impl.queue;
|
H A D | AsyncResultHandlerTest.java | 16 package org.forgerock.openam.cts.impl.queue; 25 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/ |
H A D | QueueSelectorTest.java | 16 package org.forgerock.openam.cts.impl.queue;
|
H A D | AsyncResultHandlerTest.java | 16 package org.forgerock.openam.cts.impl.queue; 25 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
|
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/ |
H A D | RequestListenerFactory.java | 89 final ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(poolConfig.getQueueSize()); 91 TimeUnit.SECONDS, queue);
|
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/ |
H A D | RequestListenerFactory.java | 86 final ArrayBlockingQueue<Runnable> queue = new ArrayBlockingQueue<Runnable>(poolConfig.getQueueSize()); 88 TimeUnit.SECONDS, queue, "RadiusRequestHandler");
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutor.java | 30 import org.forgerock.openam.cts.impl.queue.QueueSelector; 31 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration; 48 * This task queue has some specific behaviours which allow for consistent 63 * that when this queue is full, the caller is required to block. 70 * @see org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration#getQueueTimeout() 108 BlockingQueue<Task> queue = getQueue(tokenId); 109 offer(queue, task); 144 * Select a random queue to use for the query operation. 153 * Select the appropriate queue based on the given Token ID. 170 * Assign the task to the queue wit 175 offer(BlockingQueue<Task> queue, Task task) argument [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/worker/process/ |
H A D | SessionExpiryBatchHandler.java | 33 import org.forgerock.openam.cts.impl.queue.TaskDispatcher; 60 private final TaskDispatcher queue; field in class:SessionExpiryBatchHandler 66 TaskDispatcher queue, 69 this.queue = queue; 100 queue.delete(tokenId, options, stateChangeResultHandler); 65 SessionExpiryBatchHandler( TaskDispatcher queue, SessionEventType sessionEventType, StateChangeResultHandlerFactory stateChangeResultHandlerFactory) argument
|
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/ |
H A D | InMemoryNotificationBroker.java | 49 * A notification broker that uses an in-memory shared queue for incoming notifications and 53 * The queue is a fixed size and therefore notifications may be lost if the queue becomes 63 private final BlockingQueue<NotificationEntry> queue; field in class:InMemoryNotificationBroker 87 queue = new ArrayBlockingQueue<>(queueSize); 107 if (!queue.offer(entry)) { 108 logger.info("Failed to publish notification because queue is full. Notification discarded"); 144 NotificationEntry entry = queue.poll(10L, TimeUnit.SECONDS); 161 queue.drainTo(remainingEntries);
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/ |
H A D | CTSQueueConfiguration.java | 16 package org.forgerock.openam.cts.impl.queue.config; 26 import org.forgerock.openam.cts.impl.queue.QueueSelector; 35 * administrator to size and adjust the asynchronous queue and queue processors.
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/ |
H A D | CTSQueueConfiguration.java | 16 package org.forgerock.openam.cts.impl.queue.config; 26 import org.forgerock.openam.cts.impl.queue.QueueSelector; 35 * administrator to size and adjust the asynchronous queue and queue processors.
|
/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/ |
H A D | Reader.java | 36 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 D | Reader.java | 35 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 D | Reader.java | 36 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 D | Reader.java | 36 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 D | Reader.java | 35 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();
|