Searched refs:queue (Results 51 - 75 of 194) sorted by relevance

12345678

/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/queue/
H A DMonitoredResultHandlerFactory.java16 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 DSeriesTaskExecutorThreadTest.java80 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 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 DResultHandlerFactory.java16 package org.forgerock.openam.cts.impl.queue;
H A DDeleteOnQueryResultHandler.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 DMonitoredResultHandlerFactory.java16 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 DDefaultMonitoringResultHandler.java16 package org.forgerock.openam.cts.monitoring.impl.queue;
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
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 DResultHandlerFactory.java16 package org.forgerock.openam.cts.impl.queue;
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/
H A DQueueSelectorTest.java16 package org.forgerock.openam.cts.impl.queue;
H A DAsyncResultHandlerTest.java16 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 DQueueSelectorTest.java16 package org.forgerock.openam.cts.impl.queue;
H A DAsyncResultHandlerTest.java16 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 DRequestListenerFactory.java89 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 DRequestListenerFactory.java86 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 DSeriesTaskExecutor.java30 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 DSessionExpiryBatchHandler.java33 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 DInMemoryNotificationBroker.java49 * 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 DCTSQueueConfiguration.java16 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 DCTSQueueConfiguration.java16 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 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();

Completed in 90 milliseconds

12345678