Searched refs:connectionFactory (Results 1 - 25 of 147) sorted by relevance

123456

/forgerock/openidm-v4/openidm-router/src/test/java/org/forgerock/openidm/router/
H A DIDMConnectionFactoryWrapper.java28 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 DMonitoredCTSConnectionFactory.java34 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 DMonitoredCTSConnectionFactory.java34 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 DCTSDJLDAPv3PersistentSearchBuilder.java29 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 DSimpleTaskExecutorTest.java39 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 DDeadLetterQueueHandler.java42 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 DSyncFailureHandlerFactoryImpl.java62 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 DMonitoredCTSConnectionFactoryTest.java36 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 DMonitoredCTSConnectionFactoryTest.java36 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 DSimpleTaskExecutor.java42 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 DElevatedConnectionFactoryWrapper.java45 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 DElevatedConnectionFactoryWrapper.java48 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 DReconciliationServiceTest.java54 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 DSynchronizationServiceTest.java42 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 DPassthroughAuthenticator.java64 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 DResourceFunctions.java74 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 DAbstractUpgradeStep.java50 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 DAbstractUpgradeStep.java50 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 DRouterAuditEventHandler.java61 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 DUpgradeServerDefaultsStepTest.java39 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 DTaskScannerServiceTest.java41 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 DScriptRegistryServiceTest.java42 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 DSystemObjectSetServiceTest.java42 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 DUpgradeServerDefaultsStepTest.java39 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 DResourceFunctionsTest.java64 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));

Completed in 54 milliseconds

123456