Searched refs:queue (Results 26 - 50 of 194) sorted by relevance

12345678

/forgerock/opendj2/src/server/org/opends/server/loggers/
H A DParallelTextWriter.java45 * parallel unbound ie there is no queue size cap imposed.
56 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter
71 * after the queue is flushed.
80 this.queue = new ConcurrentLinkedQueue<String>();
91 * The publisher thread is responsible for emptying the queue of log records
101 * the run method of the writerThread. Run until queue is empty
115 String message = queue.poll();
151 // Put request on queue for writer
152 queue.add(record);
233 // The writer writerThread SHOULD have drained the queue
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DFakeReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeReplicationDomain
76 BlockingQueue<UpdateMsg> queue) throws ConfigException
81 this.queue = queue;
156 if (queue != null)
157 queue.add(updateMsg);
70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
H A DFakeStressReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeStressReplicationDomain
63 BlockingQueue<UpdateMsg> queue) throws ConfigException
68 this.queue = queue;
140 if (queue != null)
141 queue.add(updateMsg);
57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DFakeStressReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private final BlockingQueue<UpdateMsg> queue; field in class:FakeStressReplicationDomain
59 BlockingQueue<UpdateMsg> queue) throws ConfigException
64 this.queue = queue;
140 if (queue != null)
141 queue.add(updateMsg);
57 FakeStressReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
H A DFakeReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue; field in class:FakeReplicationDomain
96 BlockingQueue<UpdateMsg> queue) throws ConfigException
99 this.queue = queue;
166 if (queue != null)
167 queue.add(updateMsg);
94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/loggers/
H A DParallelTextWriter.java46 * parallel unbound ie there is no queue size cap imposed.
57 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter
72 * after the queue is flushed.
81 this.queue = new ConcurrentLinkedQueue<String>();
92 * The publisher thread is responsible for emptying the queue of log records
102 * the run method of the writerThread. Run until queue is empty
116 String message = queue.poll();
152 // Put request on queue for writer
153 queue.add(record);
234 // The writer writerThread SHOULD have drained the queue
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DFakeReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeReplicationDomain
76 BlockingQueue<UpdateMsg> queue) throws ConfigException
81 this.queue = queue;
156 if (queue != null)
157 queue.add(updateMsg);
70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
H A DFakeStressReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeStressReplicationDomain
63 BlockingQueue<UpdateMsg> queue) throws ConfigException
68 this.queue = queue;
140 if (queue != null)
141 queue.add(updateMsg);
57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DFakeStressReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private final BlockingQueue<UpdateMsg> queue; field in class:FakeStressReplicationDomain
59 BlockingQueue<UpdateMsg> queue) throws ConfigException
64 this.queue = queue;
140 if (queue != null)
141 queue.add(updateMsg);
57 FakeStressReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
H A DFakeReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue; field in class:FakeReplicationDomain
96 BlockingQueue<UpdateMsg> queue) throws ConfigException
99 this.queue = queue;
166 if (queue != null)
167 queue.add(updateMsg);
94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DFakeReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeReplicationDomain
76 BlockingQueue<UpdateMsg> queue) throws ConfigException
81 this.queue = queue;
156 if (queue != null)
157 queue.add(updateMsg);
70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
H A DFakeStressReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeStressReplicationDomain
63 BlockingQueue<UpdateMsg> queue) throws ConfigException
68 this.queue = queue;
140 if (queue != null)
141 queue.add(updateMsg);
57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/loggers/
H A DParallelTextWriter.java46 * parallel unbound ie there is no queue size cap imposed.
57 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter
72 * after the queue is flushed.
81 this.queue = new ConcurrentLinkedQueue<String>();
92 * The publisher thread is responsible for emptying the queue of log records
102 * the run method of the writerThread. Run until queue is empty
116 String message = queue.poll();
152 // Put request on queue for writer
153 queue.add(record);
234 // The writer writerThread SHOULD have drained the queue
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/loggers/
H A DParallelTextWriter.java45 * parallel unbound ie there is no queue size cap imposed.
56 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter
71 * after the queue is flushed.
80 this.queue = new ConcurrentLinkedQueue<String>();
91 * The publisher thread is responsible for emptying the queue of log records
101 * the run method of the writerThread. Run until queue is empty
115 String message = queue.poll();
151 // Put request on queue for writer
152 queue.add(record);
233 // The writer writerThread SHOULD have drained the queue
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DFakeStressReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private final BlockingQueue<UpdateMsg> queue; field in class:FakeStressReplicationDomain
59 BlockingQueue<UpdateMsg> queue) throws ConfigException
64 this.queue = queue;
140 if (queue != null)
142 queue.add(updateMsg);
57 FakeStressReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
H A DFakeReplicationDomain.java52 * A blocking queue that is used to send the UpdateMsg received from the
55 private BlockingQueue<UpdateMsg> queue; field in class:FakeReplicationDomain
96 BlockingQueue<UpdateMsg> queue) throws ConfigException
99 this.queue = queue;
168 if (queue != null)
170 queue.add(updateMsg);
94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/worker/process/
H A DCTSWorkerDeleteProcess.java28 import org.forgerock.openam.cts.impl.queue.TaskDispatcher;
92 private final TaskDispatcher queue; field in class:CTSWorkerDeleteProcess.TokenDeletion
95 public TokenDeletion(TaskDispatcher queue) { argument
96 this.queue = queue;
116 queue.delete(tokenId, handler);
/forgerock/openidm-v4/openidm-smartevent/src/main/java/org/forgerock/openidm/smartevent/core/
H A DBlockingPublisher.java29 * Publisher that uses the blocking linked queue to process events.
42 private static BlockingQueue queue = new LinkedBlockingQueue(QUEUE_CAPACITY); field in class:BlockingPublisher
50 EventEntry entry = (EventEntry) queue.take();
54 logger.debug("Stop processing event queue: {}", ex.getMessage());
102 queue.put(entry);
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DNamingConflictTest.java79 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
84 MultimasterReplication.createNewDomain(conf, queue);
124 // Put the message in the replay queue
127 // Make the domain replay the change from the replay queue
128 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
138 // Put the message in the replay queue
141 // Make the domain replay the change from the replay queue
143 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
168 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
173 MultimasterReplication.createNewDomain(conf, queue);
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DNamingConflictTest.java78 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
83 MultimasterReplication.createNewDomain(conf, queue);
123 // Put the message in the replay queue
126 // Make the domain replay the change from the replay queue
127 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
137 // Put the message in the replay queue
140 // Make the domain replay the change from the replay queue
142 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
167 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
172 MultimasterReplication.createNewDomain(conf, queue);
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DNamingConflictTest.java79 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
84 MultimasterReplication.createNewDomain(conf, queue);
124 // Put the message in the replay queue
127 // Make the domain replay the change from the replay queue
128 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
138 // Put the message in the replay queue
141 // Make the domain replay the change from the replay queue
143 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
168 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
173 MultimasterReplication.createNewDomain(conf, queue);
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DNamingConflictTest.java78 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
83 MultimasterReplication.createNewDomain(conf, queue);
123 // Put the message in the replay queue
126 // Make the domain replay the change from the replay queue
127 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
137 // Put the message in the replay queue
140 // Make the domain replay the change from the replay queue
142 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
167 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
172 MultimasterReplication.createNewDomain(conf, queue);
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DNamingConflictTest.java79 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
84 MultimasterReplication.createNewDomain(conf, queue);
124 // Put the message in the replay queue
127 // Make the domain replay the change from the replay queue
128 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
138 // Put the message in the replay queue
141 // Make the domain replay the change from the replay queue
143 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN);
168 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue();
173 MultimasterReplication.createNewDomain(conf, queue);
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutor.java32 import org.forgerock.openam.cts.impl.queue.QueueSelector;
33 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-v13/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;

Completed in 39 milliseconds

12345678