/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/queue/ |
H A D | TokenMonitoringResultHandler.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/ |
H A D | ConnectionType.java | 21 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 D | DefaultMonitoringResultHandlerTest.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
H A D | TokenMonitoringResultHandlerTest.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/reaper/ |
H A D | TokenDeletionTest.java | 20 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/ |
H A D | DeleteOnQueryResultHandler.java | 16 package org.forgerock.openam.cts.impl.queue;
|
H A D | AsyncResultHandlerFactory.java | 16 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 D | DefaultMonitoringResultHandler.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
H A D | TokenMonitoringResultHandler.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/queue/ |
H A D | DefaultMonitoringResultHandlerTest.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
H A D | TokenMonitoringResultHandlerTest.java | 16 package org.forgerock.openam.cts.monitoring.impl.queue;
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/worker/process/ |
H A D | TokenDeletionTest.java | 25 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
|
/forgerock/authenticator-ios-v2/ForgeRock-Authenticator/ |
H A D | FRAQRScanViewController.m | 62 [output setMetadataObjectsDelegate:self queue:dispatch_get_main_queue()];
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/ |
H A D | CTSAsyncConnectionModule.java | 24 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 D | AsyncResultHandlerFactory.java | 16 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 D | NamingConflictTest.java | 68 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 D | CTSAsyncConnectionModule.java | 24 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration;
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/ |
H A D | ConnectionType.java | 24 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
|
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/ |
H A D | CTSNotificationBroker.java | 92 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 D | EclReadAndPlay.java | 184 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 D | EclReadAndPlay.java | 183 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 D | EclReadAndPlay.java | 184 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 D | EclReadAndPlay.java | 184 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 D | EclReadAndPlay.java | 183 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 D | animation-debug.js | 473 * 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...] |