org.davidmoten.rx.jdbc.pool

Class NonBlockingConnectionPool2.Builder

java.lang.Object

org.davidmoten.rx.jdbc.pool.NonBlockingConnectionPool2.Builder

Enclosing class:

NonBlockingConnectionPool2

public static final class NonBlockingConnectionPool2.Builder
extends Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
NonBlockingConnectionPool2	build()
NonBlockingConnectionPool2.Builder	connectionProvider(ConnectionProvider cp)
NonBlockingConnectionPool2.Builder	healthy(io.reactivex.functions.Predicate<Connection> healthy)
NonBlockingConnectionPool2.Builder	idleTimeBeforeHealthCheck(long value, TimeUnit unit)
NonBlockingConnectionPool2.Builder	idleTimeBeforeHealthCheckMs(long value)
NonBlockingConnectionPool2.Builder	maxIdleTime(long value, TimeUnit unit)
NonBlockingConnectionPool2.Builder	maxIdleTimeMs(long value)
NonBlockingConnectionPool2.Builder	maxPoolSize(int maxPoolSize) Sets the maximum connection pool size.
NonBlockingConnectionPool2.Builder	returnToPoolDelayAfterHealthCheckFailure(long value, TimeUnit unit)
NonBlockingConnectionPool2.Builder	returnToPoolDelayAfterHealthCheckFailureMs(long value)
NonBlockingConnectionPool2.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.
NonBlockingConnectionPool2.Builder	url(String url)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

connectionProvider

public NonBlockingConnectionPool2.Builder connectionProvider(ConnectionProvider cp)

url

public NonBlockingConnectionPool2.Builder url(String url)

maxIdleTimeMs

public NonBlockingConnectionPool2.Builder maxIdleTimeMs(long value)

maxIdleTime

public NonBlockingConnectionPool2.Builder maxIdleTime(long value,
                                                      TimeUnit unit)

idleTimeBeforeHealthCheckMs

public NonBlockingConnectionPool2.Builder idleTimeBeforeHealthCheckMs(long value)

idleTimeBeforeHealthCheck

public NonBlockingConnectionPool2.Builder idleTimeBeforeHealthCheck(long value,
                                                                    TimeUnit unit)

healthy

public NonBlockingConnectionPool2.Builder healthy(io.reactivex.functions.Predicate<Connection> healthy)

maxPoolSize

public NonBlockingConnectionPool2.Builder maxPoolSize(int maxPoolSize)

Sets the maximum connection pool size. Default is 5.

Parameters:

maxPoolSize - maximum number of connections in the pool

Returns:

this

returnToPoolDelayAfterHealthCheckFailureMs

public NonBlockingConnectionPool2.Builder returnToPoolDelayAfterHealthCheckFailureMs(long value)

returnToPoolDelayAfterHealthCheckFailure

public NonBlockingConnectionPool2.Builder returnToPoolDelayAfterHealthCheckFailure(long value,
                                                                                   TimeUnit unit)

scheduler

public NonBlockingConnectionPool2.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. Defaults to Schedulers.from(Executors.newFixedThreadPool(maxPoolSize)). Do not set the scheduler to Schedulers.trampoline() because queries will block waiting for timeout workers. Also, do not use a single-threaded Scheduler because you may encounter StackOverflowError.

Parameters:

scheduler - scheduler to use for emitting connections and for scheduling timeouts and retries. Defaults to Schedulers.from(Executors.newFixedThreadPool(maxPoolSize)). Do not use Schedulers.trampoline().

Returns:

this

build

public NonBlockingConnectionPool2 build()