Searched refs:queue (Results 76 - 100 of 194) sorted by relevance

12345678

/forgerock/openam-v13/openam-core/src/main/java/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/sm/datalayer/api/
H A DConnectionType.java21 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/queue/
H A DDefaultMonitoringResultHandlerTest.java16 package org.forgerock.openam.cts.monitoring.impl.queue;
H A DTokenMonitoringResultHandlerTest.java16 package org.forgerock.openam.cts.monitoring.impl.queue;
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/reaper/
H A DTokenDeletionTest.java20 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A DDeleteOnQueryResultHandler.java16 package org.forgerock.openam.cts.impl.queue;
H A DAsyncResultHandlerFactory.java16 package org.forgerock.openam.cts.impl.queue;
42 * @param config Required for queue configuration.
/forgerock/openam/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/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/queue/
H A DDefaultMonitoringResultHandlerTest.java16 package org.forgerock.openam.cts.monitoring.impl.queue;
H A DTokenMonitoringResultHandlerTest.java16 package org.forgerock.openam.cts.monitoring.impl.queue;
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/worker/process/
H A DTokenDeletionTest.java25 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
/forgerock/authenticator-ios-v2/ForgeRock-Authenticator/
H A DFRAQRScanViewController.m62 [output setMetadataObjectsDelegate:self queue:dispatch_get_main_queue()];
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/
H A DCTSAsyncConnectionModule.java24 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A DAsyncResultHandlerFactory.java16 package org.forgerock.openam.cts.impl.queue;
45 * @param config Required for queue configuration.
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DNamingConflictTest.java68 private TestSynchronousReplayQueue queue; field in class:NamingConflictTest
77 queue = new TestSynchronousReplayQueue();
81 domain = MultimasterReplication.createNewDomain(conf, queue);
328 // Put the message in the replay queue
376 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/
H A DCTSAsyncConnectionModule.java24 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/
H A DConnectionType.java24 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/
H A DCTSNotificationBroker.java92 private final BlockingQueue<NotificationEntry> queue; field in class:CTSNotificationBroker
101 * @param queueSize the size of the queue of notifications waiting to be written to the CTS
125 queue = new ArrayBlockingQueue<>(queueSize);
147 if (!queue.offer(NotificationEntry.of(topic, notification))) {
148 logger.info("Failed to publish notification because queue is full. Notification discarded");
221 queue.drainTo(entries);
/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java184 System.out.println("usage: -m {draft|opends} -q {queue size} "
235 // Create a bounded blocking queue of integers
236 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
239 Reader reader = new Reader(queue, masters);
243 Writer writer = new Writer(queue, hostport);
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java183 System.out.println("usage: -m {draft|opends} -q {queue size} "
234 // Create a bounded blocking queue of integers
235 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
238 Reader reader = new Reader(queue, masters);
242 Writer writer = new Writer(queue, hostport);
/forgerock/opendj2.6.2/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java184 System.out.println("usage: -m {draft|opends} -q {queue size} "
235 // Create a bounded blocking queue of integers
236 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
239 Reader reader = new Reader(queue, masters);
243 Writer writer = new Writer(queue, hostport);
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java184 System.out.println("usage: -m {draft|opends} -q {queue size} "
235 // Create a bounded blocking queue of integers
236 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
239 Reader reader = new Reader(queue, masters);
243 Writer writer = new Writer(queue, hostport);
/forgerock/opendj2-hg/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java183 System.out.println("usage: -m {draft|opends} -q {queue size} "
234 // Create a bounded blocking queue of integers
235 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
238 Reader reader = new Reader(queue, masters);
242 Writer writer = new Writer(queue, hostport);
/forgerock/openam-v13/openam-server-only/src/main/webapp/assets/lib/yui/animation/
H A Danimation-debug.js473 * The current queue of registered animation objects.
474 * @property queue
478 var queue = [];
506 * Adds an animation instance to the animation queue.
512 queue[queue.length] = tween;
519 * removes an animation instance from the animation queue.
533 queue.splice(index, 1);
564 for (var i = 0, len = queue.length; i < len; ++i) {
565 if ( queue[
[all...]

Completed in 82 milliseconds

12345678