/forgerock/openidm-v4/openidm-router/src/test/java/org/forgerock/openidm/router/ |
H A D | IDMConnectionFactoryWrapper.java | 28 private final ConnectionFactory connectionFactory; field in class:IDMConnectionFactoryWrapper 29 public IDMConnectionFactoryWrapper(ConnectionFactory connectionFactory) { argument 30 this.connectionFactory = connectionFactory; 45 connectionFactory.close(); 50 return connectionFactory.getConnection(); 55 return connectionFactory.getConnectionAsync();
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/connections/ |
H A D | MonitoredCTSConnectionFactory.java | 34 private final ConnectionFactory<C> connectionFactory; field in class:MonitoredCTSConnectionFactory 51 * @param connectionFactory The ConnectionFactory to use to generate connections 54 public MonitoredCTSConnectionFactory(ConnectionFactory<C> connectionFactory, argument 56 this.connectionFactory = connectionFactory; 71 C response = connectionFactory.create(); 81 return connectionFactory.createAsync() 88 connectionFactory.close(); 93 return connectionFactory.isValid(connection);
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/connections/ |
H A D | MonitoredCTSConnectionFactory.java | 34 private final ConnectionFactory<C> connectionFactory; field in class:MonitoredCTSConnectionFactory 51 * @param connectionFactory The ConnectionFactory to use to generate connections 54 public MonitoredCTSConnectionFactory(ConnectionFactory<C> connectionFactory, argument 56 this.connectionFactory = connectionFactory; 71 C response = connectionFactory.create(); 81 return connectionFactory.createAsync() 88 connectionFactory.close(); 93 return connectionFactory.isValid(connection);
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ldap/ |
H A D | CTSDJLDAPv3PersistentSearchBuilder.java | 29 private final ConnectionFactory connectionFactory; field in class:CTSDJLDAPv3PersistentSearchBuilder 40 * @param connectionFactory The {@link ConnectionFactory<org.forgerock.opendj.ldap.Connection>} 43 public CTSDJLDAPv3PersistentSearchBuilder(ConnectionFactory connectionFactory) { argument 44 Reject.ifNull(connectionFactory); 45 this.connectionFactory = connectionFactory; 131 return new CTSDJLDAPv3PersistentSearch(retry, searchBaseDN, searchFilter, searchScope, connectionFactory,
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SimpleTaskExecutorTest.java | 39 private ConnectionFactory<Closeable> connectionFactory; field in class:SimpleTaskExecutorTest 43 connectionFactory = mock(ConnectionFactory.class); 45 executor = new SimpleTaskExecutor<Closeable>(connectionFactory, mock(Debug.class), adapter); 53 when(connectionFactory.create()).thenReturn(connection); 54 when(connectionFactory.isValid(connection)).thenReturn(true); 68 when(connectionFactory.create()).thenReturn(connection); 82 given(connectionFactory.create()).willReturn(connection); 83 given(connectionFactory.isValid(connection)).willReturn(true, false); 91 verify(connectionFactory, times(2)).create();
|
/forgerock/openidm-v4/openidm-provisioner-openicf/src/main/java/org/forgerock/openidm/provisioner/openicf/syncfailure/ |
H A D | DeadLetterQueueHandler.java | 42 private final ConnectionFactory connectionFactory; field in class:DeadLetterQueueHandler 47 * @param connectionFactory 49 public DeadLetterQueueHandler(ConnectionFactory connectionFactory) { argument 50 this.connectionFactory = connectionFactory; 73 connectionFactory.getConnection().create(context, request);
|
H A D | SyncFailureHandlerFactoryImpl.java | 62 protected IDMConnectionFactory connectionFactory; field in class:SyncFailureHandlerFactoryImpl 114 return new DeadLetterQueueHandler(connectionFactory); 126 new DeadLetterQueueHandler(connectionFactory));
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/connections/ |
H A D | MonitoredCTSConnectionFactoryTest.java | 36 private ConnectionFactory<Object> connectionFactory; field in class:MonitoredCTSConnectionFactoryTest 42 connectionFactory = mock(ConnectionFactory.class); 45 monitoredConnectionFactory = new MonitoredCTSConnectionFactory(connectionFactory, monitoringStore); 52 doThrow(Exception.class).when(connectionFactory).create(); 83 given(connectionFactory.createAsync()).willReturn(promise); 89 verify(connectionFactory).createAsync();
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/impl/connections/ |
H A D | MonitoredCTSConnectionFactoryTest.java | 36 private ConnectionFactory<Object> connectionFactory; field in class:MonitoredCTSConnectionFactoryTest 42 connectionFactory = mock(ConnectionFactory.class); 45 monitoredConnectionFactory = new MonitoredCTSConnectionFactory(connectionFactory, monitoringStore); 52 doThrow(Exception.class).when(connectionFactory).create(); 83 given(connectionFactory.createAsync()).willReturn(promise); 89 verify(connectionFactory).createAsync();
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SimpleTaskExecutor.java | 42 private final ConnectionFactory<T> connectionFactory; field in class:SimpleTaskExecutor 48 public SimpleTaskExecutor(ConnectionFactory connectionFactory, argument 51 this.connectionFactory = connectionFactory; 59 this.connection = connectionFactory.create(); 77 if (!connectionFactory.isValid(connection)) {
|
/forgerock/openam-v13/openam-rest/src/main/java/org/forgerock/openam/rest/ |
H A D | ElevatedConnectionFactoryWrapper.java | 45 private final ConnectionFactory connectionFactory; field in class:ElevatedConnectionFactoryWrapper 49 public ElevatedConnectionFactoryWrapper(ConnectionFactory connectionFactory, argument 51 this.connectionFactory = connectionFactory; 57 Connection connection = connectionFactory.getConnection(); 73 connectionFactory.close();
|
/forgerock/openam/openam-rest/src/main/java/org/forgerock/openam/rest/ |
H A D | ElevatedConnectionFactoryWrapper.java | 48 private final ConnectionFactory connectionFactory; field in class:ElevatedConnectionFactoryWrapper 53 public ElevatedConnectionFactoryWrapper(ConnectionFactory connectionFactory, argument 55 this.connectionFactory = connectionFactory; 62 Connection connection = connectionFactory.getConnection(); 78 connectionFactory.close();
|
/forgerock/openidm-v4/openidm-core/src/test/java/org/forgerock/openidm/sync/impl/ |
H A D | ReconciliationServiceTest.java | 54 final ConnectionFactory connectionFactory = mock(ConnectionFactory.class); 55 final ReconciliationService reconciliationService = createReconciliationService(connectionFactory); 64 when(connectionFactory.getConnection()).thenReturn(connection); 88 final ConnectionFactory connectionFactory = mock(ConnectionFactory.class); 89 final ReconciliationService reconciliationService = createReconciliationService(connectionFactory); 95 when(connectionFactory.getConnection()).thenReturn(connection); 105 private ReconciliationService createReconciliationService(final ConnectionFactory connectionFactory) { argument 107 reconciliationService.bindConnectionFactory(new IDMConnectionFactoryWrapper(connectionFactory));
|
H A D | SynchronizationServiceTest.java | 42 final IDMConnectionFactory connectionFactory = mock(IDMConnectionFactory.class); 48 synchronizationService.bindConnectionFactory(connectionFactory); 50 when(connectionFactory.getConnection()).thenReturn(connection);
|
/forgerock/openidm-v4/openidm-authnfilter/src/main/java/org/forgerock/openidm/auth/ |
H A D | PassthroughAuthenticator.java | 64 final ConnectionFactory connectionFactory = connectionFactoryProvider.get(); 65 if (connectionFactory == null) { 68 final ActionResponse result = connectionFactory.getConnection().action(context,
|
/forgerock/openidm-v4/openidm-script/src/main/java/org/forgerock/openidm/script/ |
H A D | ResourceFunctions.java | 74 public static Function<JsonValue> newCreateFunction(ConnectionFactory connectionFactory) { argument 75 return new CreateFunction(connectionFactory); 88 private CreateFunction(ConnectionFactory connectionFactory) { argument 89 super(connectionFactory); 185 return connectionFactory.getConnection().create(scope.getContext(context), cr); 190 public static Function<JsonValue> newReadFunction(ConnectionFactory connectionFactory) { argument 191 return new ReadFunction(connectionFactory); 204 private ReadFunction(ConnectionFactory connectionFactory) { argument 205 super(connectionFactory); 285 return connectionFactory 289 newUpdateFunction(ConnectionFactory connectionFactory) argument 303 UpdateFunction(ConnectionFactory connectionFactory) argument 407 newPatchFunction(ConnectionFactory connectionFactory) argument 421 PatchFunction(ConnectionFactory connectionFactory) argument 526 newQueryFunction(ConnectionFactory connectionFactory) argument 540 QueryFunction(ConnectionFactory connectionFactory) argument 717 newDeleteFunction(ConnectionFactory connectionFactory) argument 731 DeleteFunction(ConnectionFactory connectionFactory) argument 822 newActionFunction(ConnectionFactory connectionFactory) argument 836 ActionFunction(ConnectionFactory connectionFactory) argument 954 final ConnectionFactory connectionFactory; field in class:ResourceFunctions.AbstractFunction 956 AbstractFunction(ConnectionFactory connectionFactory) argument 1015 resourceFunctions(final ConnectionFactory connectionFactory) argument [all...] |
/forgerock/openam-v13/openam-upgrade/src/main/java/org/forgerock/openam/upgrade/steps/ |
H A D | AbstractUpgradeStep.java | 50 private final ConnectionFactory<Connection> connectionFactory; field in class:AbstractUpgradeStep 54 @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) { 56 this.connectionFactory = connectionFactory; 110 return connectionFactory.create(); 53 AbstractUpgradeStep(final PrivilegedAction<SSOToken> adminTokenAction, @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) argument
|
/forgerock/openam/openam-upgrade/src/main/java/org/forgerock/openam/upgrade/steps/ |
H A D | AbstractUpgradeStep.java | 50 private final ConnectionFactory<Connection> connectionFactory; field in class:AbstractUpgradeStep 54 @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) { 56 this.connectionFactory = connectionFactory; 110 return connectionFactory.create(); 53 AbstractUpgradeStep(final PrivilegedAction<SSOToken> adminTokenAction, @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) argument
|
/forgerock/openidm-v4/openidm-audit/src/main/java/org/forgerock/openidm/audit/impl/ |
H A D | RouterAuditEventHandler.java | 61 private final ConnectionFactory connectionFactory; field in class:RouterAuditEventHandler 67 @Audit final ConnectionFactory connectionFactory) { 70 this.connectionFactory = connectionFactory; 89 return newResultPromise(connectionFactory.getConnection().create(new AuditingContext(context), 103 return newResultPromise(connectionFactory.getConnection().read(new AuditingContext(context), 118 connectionFactory.getConnection().query(new AuditingContext(context), newRequest, 64 RouterAuditEventHandler( final RouterAuditEventHandlerConfiguration configuration, final EventTopicsMetaData eventTopicsMetaData, @Audit final ConnectionFactory connectionFactory) argument
|
/forgerock/openam-v13/openam-upgrade/src/test/java/org/forgerock/openam/upgrade/steps/ |
H A D | UpgradeServerDefaultsStepTest.java | 39 private ConnectionFactory connectionFactory; field in class:UpgradeServerDefaultsStepTest 44 connectionFactory = mock(ConnectionFactory.class); 45 upgradeStep = new UpgradeServerDefaultsStep(adminTokenAction, connectionFactory);
|
/forgerock/openidm-v4/openidm-scheduler/src/test/java/org/forgerock/openidm/scheduler/impl/ |
H A D | TaskScannerServiceTest.java | 41 final IDMConnectionFactory connectionFactory = mock(IDMConnectionFactory.class); 47 taskScannerService.bindConnectionFactory(connectionFactory); 49 when(connectionFactory.getConnection()).thenReturn(connection);
|
/forgerock/openidm-v4/openidm-script/src/test/java/org/forgerock/openidm/script/impl/ |
H A D | ScriptRegistryServiceTest.java | 42 final IDMConnectionFactory connectionFactory = mock(IDMConnectionFactory.class); 48 scriptRegistryService.setConnectionFactory(connectionFactory); 50 when(connectionFactory.getConnection()).thenReturn(connection);
|
/forgerock/openidm-v4/openidm-provisioner/src/test/java/org/forgerock/openidm/provisioner/impl/ |
H A D | SystemObjectSetServiceTest.java | 42 final IDMConnectionFactory connectionFactory = mock(IDMConnectionFactory.class); 48 systemObjectSetService.bindConnectionFactory(connectionFactory); 51 when(connectionFactory.getConnection()).thenReturn(connection);
|
/forgerock/openam/openam-upgrade/src/test/java/org/forgerock/openam/upgrade/steps/ |
H A D | UpgradeServerDefaultsStepTest.java | 39 private ConnectionFactory connectionFactory; field in class:UpgradeServerDefaultsStepTest 44 connectionFactory = mock(ConnectionFactory.class); 45 upgradeStep = new UpgradeServerDefaultsStep(adminTokenAction, connectionFactory);
|
/forgerock/openidm-v4/openidm-script/src/test/java/org/forgerock/openidm/script/ |
H A D | ResourceFunctionsTest.java | 64 ConnectionFactory connectionFactory = null; field in class:ResourceFunctionsTest 89 connectionFactory = Resources.newInternalConnectionFactory(router); 100 put("create", ResourceFunctions.newCreateFunction(connectionFactory)); 101 put("read", ResourceFunctions.newReadFunction(connectionFactory)); 102 put("update", ResourceFunctions.newUpdateFunction(connectionFactory)); 103 put("patch", ResourceFunctions.newPatchFunction(connectionFactory)); 104 put("query", ResourceFunctions.newQueryFunction(connectionFactory)); 105 put("delete", ResourceFunctions.newDeleteFunction(connectionFactory)); 106 put("action", ResourceFunctions.newActionFunction(connectionFactory));
|