Uses of Class
org.davidmoten.rx.jdbc.pool.NonBlockingConnectionPool.Builder

Packages that use NonBlockingConnectionPool.Builder

Package	Description
org.davidmoten.rx.jdbc
org.davidmoten.rx.jdbc.pool

Uses of NonBlockingConnectionPool.Builder in org.davidmoten.rx.jdbc

Methods in org.davidmoten.rx.jdbc that return NonBlockingConnectionPool.Builder

Modifier and Type	Method and Description
static NonBlockingConnectionPool.Builder<Database>	Database.nonBlocking()

Uses of NonBlockingConnectionPool.Builder in org.davidmoten.rx.jdbc.pool

Methods in org.davidmoten.rx.jdbc.pool that return NonBlockingConnectionPool.Builder

Modifier and Type	Method and Description
static NonBlockingConnectionPool.Builder<NonBlockingConnectionPool>	NonBlockingConnectionPool.builder()
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.connectionListener(io.reactivex.functions.Consumer<? super java.util.Optional<java.lang.Throwable>> c) Sets a listener for connection success and failure.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.connectionProvider(ConnectionProvider cp) Sets the provider of Connection objects to be used by the pool.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.connectionProvider(javax.sql.DataSource ds) Sets the provider of Connection objects to be used by the pool.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.connectionRetryInterval(long duration, java.util.concurrent.TimeUnit unit) Sets the retry interval in the case that creating/reestablishing a Connection for use in the pool fails.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.healthCheck(DatabaseType databaseType) Sets the health check for a Connection in the pool that is run only if the time since the last checkout of this Connection finished is more than idleTimeBeforeHealthCheck and a checkout of this Connection has just been requested.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.healthCheck(io.reactivex.functions.Predicate<? super java.sql.Connection> healthCheck) Sets the health check for a Connection in the pool that is run only if the time since the last checkout of this Connection finished is more than idleTimeBeforeHealthCheck and a checkout of this Connection has just been requested.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.healthCheck(java.lang.String sql) Sets the health check for a Connection in the pool that is run only if the time since the last checkout of this Connection finished is more than idleTimeBeforeHealthCheck and a checkout of this Connection has just been requested.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.idleTimeBeforeHealthCheck(long duration, java.util.concurrent.TimeUnit unit) Sets the minimum time that a connection must be idle (checked in) before on the next checkout its validity is checked using the health check function.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.maxIdleTime(long duration, java.util.concurrent.TimeUnit unit) Sets the max time a Connection can be idle (checked in to pool) before it is released from the pool (the Connection is closed).
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.maxPoolSize(int maxPoolSize) Sets the maximum connection pool size.
static NonBlockingConnectionPool.Builder<NonBlockingConnectionPool>	Pools.nonBlocking()
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.password(java.lang.String password)
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.properties(java.util.Properties properties) Sets the JDBC properties that will be passed to DriverManager.getConnection(java.lang.String, java.util.Properties).
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.property(java.lang.Object key, java.lang.Object value) Adds the given property specified by key and value to the JDBC properties that will be passed to DriverManager.getConnection(java.lang.String, java.util.Properties).
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.scheduler(io.reactivex.Scheduler scheduler) Sets the scheduler used for emitting connections (must be scheduled to another thread to break the chain of stack calls otherwise can get StackOverflowError) and for scheduling timeouts and retries.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.url(java.lang.String url) Sets the jdbc url of the Connection objects to be used by the pool.
NonBlockingConnectionPool.Builder<T>	NonBlockingConnectionPool.Builder.user(java.lang.String user)