/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/ |
H A D | LdapOptionFunction.java | 21 import org.forgerock.util.Options; 37 * @param options The {@link Options}. 41 <R extends Request> R apply(R request, Options options);
|
H A D | ETagAssertionCTSOptionFunction.java | 26 import org.forgerock.util.Options; 31 * If the {@link Options} contains a non-{@code null} {@literal etag} value then the 40 public <R extends Request> R apply(R request, Options options) {
|
H A D | DeletePreReadOptionFunction.java | 27 import org.forgerock.util.Options; 32 * If the {@link Options} contains a non-{@code null} {@code CoreTokenField[]} of fields to read 41 public <R extends Request> R apply(R request, Options options) {
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/ |
H A D | TokenStorageAdapter.java | 26 import org.forgerock.util.Options; 37 * @param options Non null Options for the operations. 42 Token create(Token token, Options options) throws DataLayerException; 48 * @param options Non null Options for the operations. 51 Token read(String tokenId, Options options) throws DataLayerException; 58 * @param options The non null Options for the operation. 63 Token update(Token previous, Token updated, Options options) throws DataLayerException; 69 * @param options The non null Options for the operation. 74 PartialToken delete(String tokenId, Options options) throws DataLayerException;
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/ |
H A D | CTSPersistentStore.java | 30 import org.forgerock.util.Options; 69 * @param options Non null Options for the operation. 74 void create(Token token, Options options) throws CoreTokenException; 89 * @param options Non null Options for the operation. 93 void createAsync(Token token, Options options) throws CoreTokenException; 109 * @param options The non null Options for the operation. 114 Token read(String tokenId, Options options) throws CoreTokenException; 140 * @param options Non null Options for the operation. 145 void update(Token token, Options options) throws CoreTokenException; 170 * @param options Non null Options fo [all...] |
H A D | CTSPersistentStoreImpl.java | 39 import org.forgerock.util.Options; 77 create(token, Options.defaultOptions()); 84 * @param options Non null Options for the operation. 88 public void create(Token token, Options options) throws CoreTokenException { 96 createAsync(token, Options.defaultOptions()); 100 public void createAsync(Token token, Options options) throws CoreTokenException { 107 return read(tokenId, Options.defaultOptions()); 111 public Token read(String tokenId, Options options) throws CoreTokenException { 124 update(token, Options.defaultOptions()); 128 public void update(Token token, Options option [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/ |
H A D | TaskFactory.java | 25 import org.forgerock.util.Options; 41 * @param options Non null. The Options for the operation. 44 public Task create(Token token, Options options, ResultHandler<Token, ?> handler) { 52 * @param options Non null. The Options for the operation. 56 public Task read(String tokenId, Options options, ResultHandler<Token, ?> handler) { 64 * @param options Non null. The Options for the operation. 67 public Task update(Token token, Options options, ResultHandler<Token, ?> handler) { 75 * @param options Non null. The Options for the operation. 78 public Task delete(String tokenId, Options options, ResultHandler<PartialToken, ?> handler) {
|
H A D | CreateTask.java | 25 import org.forgerock.util.Options; 33 private final Options options; 37 * @param options Non null Options for the operation. 40 public CreateTask(Token token, Options options, ResultHandler<Token, ?> handler) {
|
H A D | DeleteTask.java | 27 import org.forgerock.util.Options; 35 private final Options options; 39 * @param options The Options for the operation. 42 public DeleteTask(String tokenID, Options options, ResultHandler<PartialToken, ?> handler) {
|
H A D | ReadTask.java | 25 import org.forgerock.util.Options; 33 private final Options options; 37 * @param options The Options for the operation. 40 public ReadTask(String tokenId, Options options, ResultHandler<Token, ?> handler) {
|
H A D | UpdateTask.java | 25 import org.forgerock.util.Options; 33 private final Options options; 37 * @param options Non null Options for the operation. 40 public UpdateTask(Token token, Options options, ResultHandler<Token, ?> handler) {
|
/forgerock/openam/openam-rest/src/main/java/org/forgerock/openam/rest/router/ |
H A D | CTSPersistentStoreProxy.java | 31 import org.forgerock.util.Options; 68 public void create(Token token, Options options) throws CoreTokenException { 78 public void createAsync(Token token, Options options) throws CoreTokenException { 88 public Token read(String tokenId, Options options) throws CoreTokenException { 98 public void update(Token token, Options options) throws CoreTokenException { 108 public void updateAsync(Token token, Options options) throws CoreTokenException { 128 public void delete(String tokenId, Options options) throws CoreTokenException { 138 public void deleteAsync(String tokenId, Options options) throws CoreTokenException {
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/tasks/ |
H A D | DeleteTaskTest.java | 27 import org.forgerock.util.Options; 35 private Options options; 41 options = Options.defaultOptions().set(OPTIMISTIC_CONCURRENCY_CHECK_OPTION, "ETAG"); 57 .when(mockAdapter).delete(anyString(), any(Options.class));
|
H A D | CreateTaskTest.java | 29 import org.forgerock.util.Options; 39 private Options options; 47 options = Options.defaultOptions();
|
H A D | ReadTaskTest.java | 31 import org.forgerock.util.Options; 39 private Options options; 46 options = Options.defaultOptions();
|
H A D | UpdateTaskTest.java | 32 import org.forgerock.util.Options; 42 private Options options; 51 options = Options.defaultOptions().set(OPTIMISTIC_CONCURRENCY_CHECK_OPTION, "ETAG");
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/ |
H A D | CTSPersistentStoreImplTest.java | 22 import org.forgerock.util.Options; 49 verify(mockAdapter).read(eq(badger), any(Options.class)); 54 given(mockAdapter.read(anyString(), any(Options.class))).willReturn(null);
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/ |
H A D | CoreTokenAdapterTest.java | 38 import org.forgerock.util.Options; 51 private Options options; 60 options = Options.defaultOptions(); 75 verify(mockTaskDispatcher).create(eq(token), any(Options.class), any(ResultHandler.class)); 84 Options options = Options.defaultOptions(); 147 verify(mockTaskDispatcher).update(eq(token), any(Options.class), any(ResultHandler.class)); 159 verify(mockTaskDispatcher).delete(eq(tokenId), any(Options.class), any(ResultHandler.class));
|
H A D | LdapAdapterTest.java | 71 import org.forgerock.util.Options; 112 Options options = Options.defaultOptions(); 137 Options options = Options.defaultOptions(); 155 Options options = Options.defaultOptions(); 173 Options options = Options.defaultOptions(); 201 adapter.delete(tokenId, Options [all...] |
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/ |
H A D | TaskDispatcherTest.java | 31 import org.forgerock.util.Options; 41 private Options options; 53 options = Options.defaultOptions(); 102 public void shouldRejectNullTokenOnCreate(Token token, Options options, ResultHandler<Token, ?> handler) 108 public void shouldRejectNullTokenOnUpdate(Token token, Options options, ResultHandler<Token, ?> handler) 120 public void shouldRejectNullArgsOnRead(String tokenId, Options options, ResultHandler<Token, ?> handler) 171 given(mockTaskFactory.delete(eq("123"), any(Options.class), eq(mockHandler))).willReturn(task);
|
/forgerock/openidm-v4/openidm-authnfilter/src/main/java/org/forgerock/openidm/auth/modules/ |
H A D | IDMAuthModule.java | 30 import org.forgerock.util.Options; 49 Options.defaultOptions() 52 public <S> S load(Class<S> service, Options options) {
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/store/ |
H A D | TokenDataStoreTest.java | 36 import org.forgerock.util.Options; 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); 337 when(taskFactory.create(any(Token.class), any(Options.class), any(ResultHandler.class))).thenAnswer(new Answer<Object>() { 350 when(taskFactory.create(any(Token.class), any(Options.class), any(ResultHandler.class))).thenAnswer(new Answer<Object>() { 362 when(taskFactory.read(anyString(), any(Options [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/ |
H A D | TaskDispatcher.java | 42 import org.forgerock.util.Options;
103 * @param options Non null Options for the operation.
107 public void create(Token token, Options options, ResultHandler<Token, ?> handler) throws CoreTokenException {
127 * @param options Non null Options for the operation.
132 public void read(String tokenId, Options options, ResultHandler<Token, ?> handler) throws CoreTokenException {
148 * @param options Non null Options for the operation.
153 public void update(Token token, Options options, ResultHandler<Token, ?> handler) throws CoreTokenException {
175 delete(tokenId, Options.defaultOptions(), handler);
185 * @param options Non null Options for the operation.
191 public void delete(String tokenId, Options option [all...] |
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/worker/process/ |
H A D | SessionExpiryBatchHandlerTest.java | 39 import org.forgerock.util.Options; 83 ArgumentCaptor<Options> optionsCaptor = ArgumentCaptor.forClass(Options.class); 85 Options options = optionsCaptor.getValue(); 99 ArgumentCaptor<Options> optionsCaptor = ArgumentCaptor.forClass(Options.class); 101 Options options = optionsCaptor.getValue();
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/store/ |
H A D | TokenDataStore.java | 38 import org.forgerock.util.Options; 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.update(token, Options.defaultOptions(), handler)); 163 taskExecutor.execute(id, taskFactory.delete(id, Options.defaultOptions(), handler));
|