/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | ResourceSetConnectionModule.java | 57 * @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 D | UmaAuditConnectionModule.java | 56 * @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 D | UmaPendingRequestConnectionModule.java | 57 * @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 D | ResourceSetConnectionModule.java | 57 * @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 D | UmaAuditConnectionModule.java | 56 * @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 D | UmaPendingRequestConnectionModule.java | 57 * @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 D | TaskDispatcher.java | 52 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 D | TaskDispatcher.java | 63 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 D | TokenDataStore.java | 55 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 D | TokenDataStoreTest.java | 49 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 D | TokenDataStore.java | 52 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 D | TokenDataStoreTest.java | 47 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...] |