Searched refs:Task (Results 1 - 25 of 673) sorted by relevance

1234567891011>>

/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/
H A DTask.java19 * Represents a Task which can be performed by a the implementation.
21 * enough state to be processed by the Task Processor.
25 public interface Task { interface
H A DQueueTimeoutException.java22 * Task on the queue.
30 public QueueTimeoutException(Task task) {
33 "Task: {0}",
43 public QueueTimeoutException(Task task, InterruptedException error) {
46 "Task: {0}",
H A DTaskExecutor.java29 void execute(String tokenId, Task task) throws DataLayerException;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/
H A DQueueTimeoutException.java22 * Task on the queue.
30 public QueueTimeoutException(Task task) {
33 "Task: {0}",
43 public QueueTimeoutException(Task task, InterruptedException error) {
46 "Task: {0}",
H A DTask.java20 * Represents a Task which can be performed by a the implementation.
22 * enough state to be processed by the Task Processor.
26 public interface Task { interface
H A DTaskExecutor.java28 void execute(String tokenId, Task task) throws DataLayerException;
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/
H A DTaskFactory.java23 import org.forgerock.openam.sm.datalayer.api.Task;
27 * Generates instances of specific Task implementations.
31 * @see org.forgerock.openam.sm.datalayer.api.Task
39 * @return Non null Token creation Task.
41 public Task create(Token token, ResultHandler<Token, ?> handler) {
49 * @return Non null Token read Task.
51 public Task read(String tokenId, ResultHandler<Token, ?> handler) {
58 * @return Non null Token update Task.
60 public Task update(Token token, ResultHandler<Token, ?> handler) {
67 * @return Non null Token delete Task
[all...]
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorThreadTest.java22 import org.forgerock.openam.sm.datalayer.api.Task;
57 processor.setQueue(generateTestQueue(mock(Task.class)));
69 Task mockTask = mock(Task.class);
79 private BlockingQueue<Task> generateTestQueue(final Task first) throws InterruptedException {
80 BlockingQueue<Task> queue = mock(BlockingQueue.class);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/
H A DTaskFactory.java23 import org.forgerock.openam.sm.datalayer.api.Task;
28 * Generates instances of specific Task implementations.
32 * @see org.forgerock.openam.sm.datalayer.api.Task
42 * @return Non null. Token creation Task.
44 public Task create(Token token, Options options, ResultHandler<Token, ?> handler) {
54 * @return Non null. Token read Task.
56 public Task read(String tokenId, Options options, ResultHandler<Token, ?> handler) {
65 * @return Non null. Token update Task.
67 public Task update(Token token, Options options, ResultHandler<Token, ?> handler) {
76 * @return Non null. Token delete Task
[all...]
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutorThreadTest.java22 import org.forgerock.openam.sm.datalayer.api.Task;
57 processor.setQueue(generateTestQueue(mock(Task.class)));
69 Task mockTask = mock(Task.class);
79 private BlockingQueue<Task> generateTestQueue(final Task first) throws InterruptedException {
80 BlockingQueue<Task> queue = mock(BlockingQueue.class);
H A DSimpleTaskExecutorTest.java21 import org.forgerock.openam.sm.datalayer.api.Task;
42 Task task = mock(Task.class);
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcherTest.java26 import org.forgerock.openam.sm.datalayer.api.Task;
95 Task task = mock(Task.class);
110 Task task = mock(Task.class);
123 Task task = mock(Task.class);
136 Task task = mock(Task.class);
150 Task tas
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutor.java38 import org.forgerock.openam.sm.datalayer.api.Task;
53 * {@link Task}s themselves are keyed by the Token ID of the request.
75 private BlockingQueue<Task>[] taskQueues;
107 public void execute(String tokenId, Task task) throws DataLayerException {
108 BlockingQueue<Task> queue = getQueue(tokenId);
139 debug("Created {0} Task Processors", processors);
147 private BlockingQueue<Task> getQueueForQuery() {
160 private BlockingQueue<Task> getQueue(String tokenId) {
172 * @param task Task to add.
173 * @throws org.forgerock.openam.sm.datalayer.api.QueueTimeoutException If the timeout expired before the Task wa
[all...]
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/store/
H A DTokenDataStoreTest.java32 import org.forgerock.openam.sm.datalayer.api.Task;
64 final Task task = mock(Task.class);
86 final Task task = mock(Task.class);
106 final Task task = mock(Task.class);
122 final Task task = mock(Task.class);
124 when(taskFactory.read(anyString(), any(ResultHandler.class))).thenAnswer(new Answer<Task>() {
[all...]
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/store/
H A DTokenDataStoreTest.java31 import org.forgerock.openam.sm.datalayer.api.Task;
63 Task task = givenCreateTaskCompletesSuccessfully();
90 final Task task = mock(Task.class);
107 Task task = givenReadTaskCompletesSuccessfully(token);
149 doThrow(DataLayerException.class).when(taskExecutor).execute(anyString(), any(Task.class));
160 Task readTask = givenReadTaskCompletesSuccessfully("123", token);
161 Task updateTask = givenUpdateTaskCompletesSuccessfully(token);
209 Task updateTask = givenUpdateTaskCompletesSuccessfully(token);
221 Task tas
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/tasks/
H A DTasksTestCase.java35 import org.opends.server.backends.task.Task;
125 public static Task getTask(final DN taskEntryDN) throws Exception
133 return timer.repeatUntilSuccess(new Callable<Task>()
136 public Task call() throws Exception
138 Task task = taskBackend.getScheduledTask(taskEntryDN);
156 public static Task getDoneTask(final DN taskEntryDN) throws Exception
158 final Task task = getTask(taskEntryDN);
164 return timer.repeatUntilSuccess(new Callable<Task>()
167 public Task call() throws Exception
170 "Task "
[all...]
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DSeriesTaskExecutor.java38 import org.forgerock.openam.sm.datalayer.api.Task;
53 * {@link Task}s themselves are keyed by the Token ID of the request.
75 private BlockingQueue<Task>[] taskQueues;
107 public void execute(String tokenId, Task task) throws DataLayerException {
108 BlockingQueue<Task> queue = getQueue(tokenId);
132 taskQueues[ii] = new LinkedBlockingQueue<Task>(configuration.getQueueSize());
139 debug("Created {0} Task Processors", processors);
147 private BlockingQueue<Task> getQueueForQuery() {
160 private BlockingQueue<Task> getQueue(String tokenId) {
172 * @param task Task t
[all...]
/forgerock/opendj2/src/server/org/opends/server/backends/task/
H A DTaskThread.java81 super("Task Thread " + threadID);
102 public Task getTask()
115 public void setTask(Task task)
197 Task task = getAssociatedTask();
217 Task task = getAssociatedTask();
226 Task completedTask = getAssociatedTask();
237 Task task = getAssociatedTask();
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/task/
H A DTaskThread.java85 super("Task Thread " + threadID);
106 public Task getTask()
119 public void setTask(Task task)
201 Task task = getAssociatedTask();
221 Task task = getAssociatedTask();
230 Task completedTask = getAssociatedTask();
241 Task task = getAssociatedTask();
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/task/
H A DTaskThread.java85 super("Task Thread " + threadID);
106 public Task getTask()
119 public void setTask(Task task)
201 Task task = getAssociatedTask();
221 Task task = getAssociatedTask();
230 Task completedTask = getAssociatedTask();
241 Task task = getAssociatedTask();
/forgerock/opendj2-hg/src/server/org/opends/server/backends/task/
H A DTaskThread.java81 super("Task Thread " + threadID);
102 public Task getTask()
115 public void setTask(Task task)
197 Task task = getAssociatedTask();
217 Task task = getAssociatedTask();
226 Task completedTask = getAssociatedTask();
237 Task task = getAssociatedTask();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/task/
H A DTaskThread.java85 super("Task Thread " + threadID);
106 public Task getTask()
119 public void setTask(Task task)
201 Task task = getAssociatedTask();
221 Task task = getAssociatedTask();
230 Task completedTask = getAssociatedTask();
241 Task task = getAssociatedTask();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/task/
H A DTaskThread.java75 super("Task Thread " + threadID);
96 public Task getTask()
109 public void setTask(Task task)
185 Task task = getAssociatedTask();
199 Task task = getAssociatedTask();
204 Task completedTask = getAssociatedTask();
215 Task task = getAssociatedTask();
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcherTest.java27 import org.forgerock.openam.sm.datalayer.api.Task;
142 Task task = mock(Task.class);
157 Task task = mock(Task.class);
170 Task task = mock(Task.class);
183 Task task = mock(Task.class);
197 Task tas
[all...]
/forgerock/opendj2/src/build-tools/org/opends/build/tools/
H A DCreateVersionString.java31 import org.apache.tools.ant.Task;
39 public class CreateVersionString extends Task

Completed in 169 milliseconds

1234567891011>>