@Test public void shouldUseFactoryForAsynConnection() { factory.getConnectionAsync(mock(ResultHandler.class)); verify(mockDLCF).getConnectionAsync(any(ResultHandler.class)); }
public FutureResult<Connection> getConnectionAsync(ResultHandler<? super Connection> resultHandler) { try { readLock.lock(); return factory.getConnectionAsync(resultHandler); } finally { readLock.unlock(); } }
CTSConnectionFactory implements ConnectionFactory, ShutdownListener { public FutureResult<Connection> getConnectionAsync(ResultHandler<? super Connection> resultHandler) { try { readLock.lock(); return factory.getConnectionAsync(resultHandler); } finally { readLock.unlock(); } } }
CTSConnectionFactory implements ConnectionFactory, ShutdownListener { public FutureResult<Connection> getConnectionAsync(ResultHandler<? super Connection> resultHandler) { try { readLock.lock(); return factory.getConnectionAsync(resultHandler); } finally { readLock.unlock(); } } @Inject  CTSConnectionFactory(DataLayerConnectionFactory dlcf, LDAPConfig ldapConfig,
                                ExternalTokenConfig external, @Named(CoreTokenConstants.CTS_DEBUG) Debug debug); }
CTSConnectionFactory implements ConnectionFactory, ShutdownListener { public FutureResult<Connection> getConnectionAsync(ResultHandler<? super Connection> resultHandler) { try { readLock.lock(); return factory.getConnectionAsync(resultHandler); } finally { readLock.unlock(); } } @Inject  CTSConnectionFactory(DataLayerConnectionFactory dlcf, LDAPConfig ldapConfig,
                                ExternalTokenConfig external, @Named(CoreTokenConstants.CTS_DEBUG) Debug debug); void updateConnection(); Connection getConnection(); FutureResult<Connection> getConnectionAsync(ResultHandler<? super Connection> resultHandler); void close(); void shutdown(); }
CTSConnectionFactory implements ConnectionFactory, ShutdownListener { public FutureResult<Connection> getConnectionAsync(ResultHandler<? super Connection> resultHandler) { try { readLock.lock(); return factory.getConnectionAsync(resultHandler); } finally { readLock.unlock(); } } @Inject  CTSConnectionFactory(DataLayerConnectionFactory dlcf, LDAPConfig ldapConfig,
                                ExternalTokenConfig external, @Named(CoreTokenConstants.CTS_DEBUG) Debug debug); void updateConnection(); Connection getConnection(); FutureResult<Connection> getConnectionAsync(ResultHandler<? super Connection> resultHandler); void close(); void shutdown();  }