Searched defs:connectionFactory (Results 1 - 25 of 136) sorted by relevance

123456

/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));
/forgerock/openam-v13/openam-rest/src/test/java/org/forgerock/openam/rest/
H A DElevatedConnectionFactoryWrapperTest.java60 private ConnectionFactory connectionFactory; field in class:ElevatedConnectionFactoryWrapperTest
65 connectionFactory = new ElevatedConnectionFactoryWrapper(internalConnectionFactory, ssoTokenPrivilegedAction);
86 try (Connection connection = connectionFactory.getConnection()) {
/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-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/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
H A DResavePoliciesStep.java56 @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) {
57 super(adminTokenAction, connectionFactory);
55 ResavePoliciesStep(final PrivilegedAction<SSOToken> adminTokenAction, @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) argument
/forgerock/openam-v13/openam-upgrade/src/test/java/org/forgerock/openam/upgrade/steps/
H A DRemoveRedundantDefaultApplicationTest.java52 private ConnectionFactory connectionFactory; field in class:RemoveRedundantDefaultApplicationTest
66 applicationService, ssoTokenAction, connectionFactory);
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-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/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));
/forgerock/openidm-v4/openidm-audit/src/test/java/org/forgerock/openidm/audit/impl/
H A DRouterAuditEventHandlerTest.java57 private ConnectionFactory connectionFactory; field in class:RouterAuditEventHandlerTest
67 connectionFactory = Resources.newInternalConnectionFactory(router);
75 config, EventTopicsMetaDataBuilder.coreTopicSchemas().build(), connectionFactory);
/forgerock/openidm-v4/openidm-core/src/test/java/org/forgerock/openidm/managed/
H A DCollectionRelationshipProviderTest.java39 private ConnectionFactory connectionFactory; field in class:CollectionRelationshipProviderTest
92 connectionFactory = mock(ConnectionFactory.class);
109 when(connectionFactory.getConnection()).thenReturn(connection);
118 CollectionRelationshipProvider provider = new CollectionRelationshipProvider(connectionFactory,
H A DRelationshipValidatorTest.java54 private ConnectionFactory connectionFactory; field in class:RelationshipValidatorTest
61 connectionFactory = mock(ConnectionFactory.class);
74 when(connectionFactory.getConnection()).thenReturn(connection);
80 CollectionRelationshipProvider relationshipProvider = new CollectionRelationshipProvider(connectionFactory,
127 when(connectionFactory.getConnection()).thenReturn(connection);
131 CollectionRelationshipProvider relationshipProvider = new CollectionRelationshipProvider(connectionFactory,
/forgerock/openidm-v4/openidm-maintenance/src/main/java/org/forgerock/openidm/maintenance/upgrade/
H A DConfigUpdater.java58 protected IDMConnectionFactory connectionFactory; field in class:ConfigUpdater
74 connectionFactory.getConnection().patch(context, request);
/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);
/forgerock/openam/openam-rest/src/test/java/org/forgerock/openam/rest/
H A DElevatedConnectionFactoryWrapperTest.java64 private ConnectionFactory connectionFactory; field in class:ElevatedConnectionFactoryWrapperTest
72 connectionFactory = new ElevatedConnectionFactoryWrapper(internalConnectionFactory, ssoTokenPrivilegedAction,
101 try (Connection connection = connectionFactory.getConnection()) {
/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/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/test/java/org/forgerock/openam/upgrade/steps/
H A DRemoveRedundantDefaultApplicationTest.java54 private ConnectionFactory connectionFactory; field in class:RemoveRedundantDefaultApplicationTest
69 applicationServiceFactory, ssoTokenAction, connectionFactory);
/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-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-v13/openam-selfservice/src/main/java/org/forgerock/openam/selfservice/
H A DSelfServiceGuiceModule.java126 UserUpdateService getUserUpdateService(@SelfService ConnectionFactory connectionFactory) { argument
127 return new UserUpdateService(connectionFactory,
/forgerock/openam-v13/openam-upgrade/src/main/java/org/forgerock/openam/upgrade/steps/policy/
H A DAbstractEntitlementUpgradeStep.java52 @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) {
53 super(adminTokenAction, connectionFactory);
50 AbstractEntitlementUpgradeStep( final PrivilegedAction<SSOToken> adminTokenAction, @DataLayer(ConnectionType.DATA_LAYER) final ConnectionFactory connectionFactory) argument
/forgerock/openidm-v4/openidm-authnfilter/src/main/java/org/forgerock/openidm/auth/
H A DIDMAuditApi.java61 private final ConnectionFactory connectionFactory; field in class:IDMAuditApi
63 IDMAuditApi(ConnectionFactory connectionFactory) { argument
64 this.connectionFactory = connectionFactory;
108 connectionFactory.getConnection().create(context, createRequest);
/forgerock/openidm-v4/openidm-config/src/main/java/org/forgerock/openidm/config/manage/
H A DConfigAuditEventLogger.java57 * @param connectionFactory factory used to make crest call to audit service.
60 Context context, ConnectionFactory connectionFactory) {
80 return connectionFactory.getConnection().create(context,
59 log(ConfigAuditState configAuditState, Request request, Context context, ConnectionFactory connectionFactory) argument

Completed in 116 milliseconds

123456