Searched defs:taskFactory (Results 1 - 12 of 12) sorted by relevance

/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DResourceSetConnectionModule.java57 * @param taskFactory The task factory for creating data store operations.
61 TaskFactory taskFactory) {
62 super((JavaBeanAdapter<ResourceSetDescription>) adapterFactory.create(ResourceSetDescription.class), taskExecutor, taskFactory);
60 ResourceSetTokenDataStore(JavaBeanAdapterFactory adapterFactory, TaskExecutor taskExecutor, TaskFactory taskFactory) argument
H A DUmaAuditConnectionModule.java56 * @param taskFactory The task factory for creating data store operations.
60 TaskFactory taskFactory) {
62 taskFactory);
59 UmaAuditTokenDatastore(JavaBeanAdapterFactory adapterFactory, TaskExecutor taskExecutor, TaskFactory taskFactory) argument
H A DUmaPendingRequestConnectionModule.java57 * @param taskFactory The task factory for creating data store operations.
61 TaskFactory taskFactory) {
62 super((JavaBeanAdapter<UmaPendingRequest>) adapterFactory.create(UmaPendingRequest.class), taskExecutor, taskFactory);
60 UmaPendingRequestTokenDataStore(JavaBeanAdapterFactory adapterFactory, TaskExecutor taskExecutor, TaskFactory taskFactory) argument
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DResourceSetConnectionModule.java57 * @param taskFactory The task factory for creating data store operations.
61 TaskFactory taskFactory) {
62 super((JavaBeanAdapter<ResourceSetDescription>) adapterFactory.create(ResourceSetDescription.class), taskExecutor, taskFactory);
60 ResourceSetTokenDataStore(JavaBeanAdapterFactory adapterFactory, TaskExecutor taskExecutor, TaskFactory taskFactory) argument
H A DUmaAuditConnectionModule.java56 * @param taskFactory The task factory for creating data store operations.
60 TaskFactory taskFactory) {
62 taskFactory);
59 UmaAuditTokenDatastore(JavaBeanAdapterFactory adapterFactory, TaskExecutor taskExecutor, TaskFactory taskFactory) argument
H A DUmaPendingRequestConnectionModule.java57 * @param taskFactory The task factory for creating data store operations.
61 TaskFactory taskFactory) {
62 super((JavaBeanAdapter<UmaPendingRequest>) adapterFactory.create(UmaPendingRequest.class), taskExecutor, taskFactory);
60 UmaPendingRequestTokenDataStore(JavaBeanAdapterFactory adapterFactory, TaskExecutor taskExecutor, TaskFactory taskFactory) argument
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcher.java52 private final TaskFactory taskFactory; field in class:TaskDispatcher
58 * @param taskFactory Required to create Task instances.
62 public TaskDispatcher(@DataLayer(ConnectionType.CTS_ASYNC) TaskFactory taskFactory, argument
64 this.taskFactory = taskFactory;
93 taskExecutor.execute(token.getTokenId(), taskFactory.create(token, handler));
117 taskExecutor.execute(tokenId, taskFactory.read(tokenId, handler));
137 taskExecutor.execute(token.getTokenId(), taskFactory.update(token, handler));
158 taskExecutor.execute(tokenId, taskFactory.delete(tokenId, handler));
184 taskExecutor.execute(null, taskFactory
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/
H A DTaskDispatcher.java63 private final TaskFactory taskFactory; field in class:TaskDispatcher
74 * @param taskFactory Required to create Task instances.
78 public TaskDispatcher(@DataLayer(ConnectionType.CTS_ASYNC) TaskFactory taskFactory, argument
80 this.taskFactory = taskFactory;
110 taskExecutor.execute(token.getTokenId(), taskFactory.create(token, options, handler));
135 taskExecutor.execute(tokenId, taskFactory.read(tokenId, options, handler));
156 taskExecutor.execute(token.getTokenId(), taskFactory.update(token, options, handler));
194 taskExecutor.execute(tokenId, taskFactory.delete(tokenId, options, handler));
219 taskExecutor.execute(null, taskFactory
[all...]
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/store/
H A DTokenDataStore.java55 private final TaskFactory taskFactory; field in class:TokenDataStore
62 * @param taskFactory The task factory for creating data store operations.
64 public TokenDataStore(JavaBeanAdapter<T> adapter, TaskExecutor taskExecutor, TaskFactory taskFactory) { argument
65 this(adapter, taskExecutor, taskFactory,
70 TokenDataStore(JavaBeanAdapter<T> adapter, TaskExecutor taskExecutor, TaskFactory taskFactory, Debug debug) { argument
74 this.taskFactory = taskFactory;
88 taskExecutor.execute(token.getTokenId(), taskFactory.create(token, handler));
114 taskExecutor.execute(id, taskFactory.read(id, handler));
145 taskExecutor.execute(token.getTokenId(), taskFactory
[all...]
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/store/
H A DTokenDataStoreTest.java49 private TaskFactory taskFactory; field in class:TokenDataStoreTest
56 taskFactory = mock(TaskFactory.class);
57 this.store = new TokenDataStore<Object>(adapter, taskExecutor, taskFactory, mock(Debug.class));
66 when(taskFactory.create(any(Token.class), any(ResultHandler.class))).thenAnswer(new Answer<Object>() {
78 verify(taskFactory).create(eq(token), any(ResultHandler.class));
88 when(taskFactory.create(any(Token.class), any(ResultHandler.class))).thenAnswer(new Answer<Object>() {
108 when(taskFactory.create(any(Token.class), any(ResultHandler.class))).thenReturn(task);
124 when(taskFactory.read(anyString(), any(ResultHandler.class))).thenAnswer(new Answer<Task>() {
136 verify(taskFactory).read(eq("123"), any(ResultHandler.class));
148 when(taskFactory
[all...]
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/store/
H A DTokenDataStore.java52 private final TaskFactory taskFactory; field in class:TokenDataStore
59 * @param taskFactory The task factory for creating data store operations.
61 public TokenDataStore(JavaBeanAdapter<T> adapter, TaskExecutor taskExecutor, TaskFactory taskFactory) { argument
62 this(adapter, taskExecutor, taskFactory,
67 TokenDataStore(JavaBeanAdapter<T> adapter, TaskExecutor taskExecutor, TaskFactory taskFactory, Debug debug) { argument
71 this.taskFactory = taskFactory;
85 taskExecutor.execute(token.getTokenId(), taskFactory.create(token, Options.defaultOptions(), handler));
111 taskExecutor.execute(id, taskFactory.read(id, Options.defaultOptions(), handler));
142 taskExecutor.execute(token.getTokenId(), taskFactory
[all...]
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/store/
H A DTokenDataStoreTest.java47 private TaskFactory taskFactory; field in class:TokenDataStoreTest
54 taskFactory = mock(TaskFactory.class);
55 this.store = new TokenDataStore<>(adapter, taskExecutor, taskFactory, mock(Debug.class));
69 verify(taskFactory).create(eq(token), any(Options.class), any(ResultHandler.class));
92 when(taskFactory.create(any(Token.class), any(Options.class), any(ResultHandler.class))).thenReturn(task);
113 verify(taskFactory).read(eq("123"), any(Options.class), any(ResultHandler.class));
167 verify(taskFactory).update(eq(token), any(Options.class), any(ResultHandler.class));
227 verify(taskFactory).delete(eq("123"), any(Options.class), any(ResultHandler.class));
246 when(taskFactory.delete(anyString(), any(Options.class), any(ResultHandler.class))).thenReturn(task);
268 when(taskFactory
[all...]

Completed in 57 milliseconds